Add support for ABATED alerts within CDAP TCA
[dcaegen2/analytics/tca.git] / dcae-analytics-tca / src / test / java / org / openecomp / dcae / apod / analytics / tca / processor / TCACEFPolicyEventNameFilterTest.java
@@ -32,15 +32,15 @@ import static org.junit.Assert.assertThat;
 /**
  * @author Rajiv Singla . Creation Date: 12/19/2016.
  */
-public class TCACEFPolicyFunctionalRoleFilterTest extends BaseAnalyticsTCAUnitTest {
+public class TCACEFPolicyEventNameFilterTest extends BaseAnalyticsTCAUnitTest {
 
-    private TCACEFPolicyFunctionalRoleFilter tcacefPolicyFunctionalRoleFilter;
+    private TCACEFPolicyEventNameFilter tcacefPolicyEventNameFilter;
     private TCACEFProcessorContext processorContext;
     private EventListener cefEventListener;
 
     @Before
     public void before() throws Exception {
-        tcacefPolicyFunctionalRoleFilter = new TCACEFPolicyFunctionalRoleFilter();
+        tcacefPolicyEventNameFilter = new TCACEFPolicyEventNameFilter();
         processorContext = new TCACEFProcessorContext("", getSampleTCAPolicy());
         cefEventListener = getCEFEventListener();
         processorContext.setCEFEventListener(cefEventListener);
@@ -48,9 +48,9 @@ public class TCACEFPolicyFunctionalRoleFilterTest extends BaseAnalyticsTCAUnitTe
 
     @Test
     public void testProcessMessageWhenMessageIsValid() throws Exception {
-        tcacefPolicyFunctionalRoleFilter.processMessage(processorContext);
+        tcacefPolicyEventNameFilter.processMessage(processorContext);
         assertThat("Processing must finish successfully",
-                tcacefPolicyFunctionalRoleFilter.getProcessingState(),
+                tcacefPolicyEventNameFilter.getProcessingState(),
                 is(ProcessingState.PROCESSING_FINISHED_SUCCESSFULLY));
     }
 
@@ -58,17 +58,17 @@ public class TCACEFPolicyFunctionalRoleFilterTest extends BaseAnalyticsTCAUnitTe
     public void testProcessMessageWhenCEFEventIsNull() throws Exception {
         cefEventListener.setEvent(null);
         processorContext.setCEFEventListener(cefEventListener);
-        tcacefPolicyFunctionalRoleFilter.processMessage(processorContext);
+        tcacefPolicyEventNameFilter.processMessage(processorContext);
         assertThat("Processing must terminate early",
-                tcacefPolicyFunctionalRoleFilter.getProcessingState(), is(ProcessingState.PROCESSING_TERMINATED_EARLY));
+                tcacefPolicyEventNameFilter.getProcessingState(), is(ProcessingState.PROCESSING_TERMINATED_EARLY));
     }
 
     @Test
-    public void testProcessMessageWhenPolicyFunctionalRoleDoesNotMatchMessageFunctionalRole() throws Exception {
-        cefEventListener.getEvent().getCommonEventHeader().setFunctionalRole("someNonPolicyFunctionalRole");
-        tcacefPolicyFunctionalRoleFilter.processMessage(processorContext);
+    public void testProcessMessageWhenPolicyEventNameDoesNotMatchMessageEventName() throws Exception {
+        cefEventListener.getEvent().getCommonEventHeader().setEventName("someNonPolicyEventName");
+        tcacefPolicyEventNameFilter.processMessage(processorContext);
         assertThat("Processing must terminate early",
-                tcacefPolicyFunctionalRoleFilter.getProcessingState(), is(ProcessingState.PROCESSING_TERMINATED_EARLY));
+                tcacefPolicyEventNameFilter.getProcessingState(), is(ProcessingState.PROCESSING_TERMINATED_EARLY));
     }