Merge "Added STD sim 2.0.0 tests"
[nonrtric.git] / policy-agent / src / test / java / org / oransc / policyagent / dmaap / DmaapMessageConsumerTest.java
index a78fde0..92c4bb0 100644 (file)
@@ -147,8 +147,16 @@ class DmaapMessageConsumerTest {
         setUpMrConfig();
         messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock));
 
-        String message =
-            "{\"apiVersion\":\"1.0\",\"operation\":\"GET\",\"correlationId\":\"1592341013115594000\",\"originatorId\":\"849e6c6b420\",\"payload\":{},\"requestId\":\"23343221\", \"target\":\"policy-agent\",\"timestamp\":\"2020-06-16 20:56:53.115665\",\"type\":\"request\",\"url\":\"/rics\"}";
+        String message = "{\"apiVersion\":\"1.0\"," //
+            + "\"operation\":\"GET\"," //
+            + "\"correlationId\":\"1592341013115594000\"," //
+            + "\"originatorId\":\"849e6c6b420\"," //
+            + "\"payload\":{}," //
+            + "\"requestId\":\"23343221\", " //
+            + "\"target\":\"policy-agent\"," //
+            + "\"timestamp\":\"2020-06-16 20:56:53.115665\"," //
+            + "\"type\":\"request\"," //
+            + "\"url\":\"/rics\"}";
         String messages = "[" + message + "]";
 
         doReturn(false, true).when(messageConsumerUnderTest).isStopped();
@@ -164,7 +172,7 @@ class DmaapMessageConsumerTest {
         ArgumentCaptor<String> captor = ArgumentCaptor.forClass(String.class);
         verify(messageHandlerMock).handleDmaapMsg(captor.capture());
         String messageAfterJsonParsing = captor.getValue();
-        assertThat(messageAfterJsonParsing.contains("apiVersion")).isTrue();
+        assertThat(messageAfterJsonParsing).contains("apiVersion");
 
         verifyNoMoreInteractions(messageHandlerMock);
     }