2 * ===============================LICENSE_START======================================
4 * ================================================================================
5 * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============================LICENSE_END===========================================
21 package org.openecomp.dcae.apod.analytics.common.service.processor;
23 import org.junit.Test;
24 import org.openecomp.dcae.apod.analytics.common.BaseAnalyticsCommonUnitTest;
25 import org.openecomp.dcae.apod.analytics.common.exception.MessageProcessingException;
27 import static org.hamcrest.CoreMatchers.is;
28 import static org.junit.Assert.assertThat;
29 import static org.junit.Assert.assertTrue;
32 * @author Rajiv Singla . Creation Date: 12/12/2016.
34 public class AbstractMessageProcessorTest extends BaseAnalyticsCommonUnitTest {
38 public void testPreProcessorWhenProcessingContextFlagIsTrue() throws Exception {
39 TestMessageProcessor1 messageProcessor1 = new TestMessageProcessor1();
40 final TestProcessorContext processorContext =
41 new TestProcessorContext(TEST_MESSAGE_PROCESSOR_MESSAGE, true);
42 final TestProcessorContext testProcessorContext = messageProcessor1.preProcessor(processorContext);
43 assertThat("Processing flag must be true",
44 testProcessorContext.canProcessingContinue(), is(true));
47 @Test(expected = MessageProcessingException.class)
48 public void testPreProcessorWhenProcessingContextFlagIsFalse() throws Exception {
49 TestMessageProcessor1 messageProcessor1 = new TestMessageProcessor1();
50 final TestProcessorContext testProcessorContext =
51 new TestProcessorContext(TEST_MESSAGE_PROCESSOR_MESSAGE, false);
52 messageProcessor1.preProcessor(testProcessorContext);
56 public void testPostProcessorWhenProcessingStateIsNotFinishedSuccessfully() throws Exception {
57 TestMessageProcessor1 messageProcessor1 = new TestMessageProcessor1();
58 final ProcessingState processingState = messageProcessor1.getProcessingState();
59 assertTrue("Processing state is not processing finished successfully",
60 processingState != ProcessingState.PROCESSING_FINISHED_SUCCESSFULLY);
61 final TestProcessorContext processorContext =
62 new TestProcessorContext(TEST_MESSAGE_PROCESSOR_MESSAGE, true);
63 final TestProcessorContext testProcessorContext = messageProcessor1.postProcessor(processorContext);
64 assertThat("Processing flag must be false",
65 testProcessorContext.canProcessingContinue(), is(false));