X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fdmaap%2FDmaapMessageConsumerTest.java;h=92c4bb0a7b424a6ec4c629d596e7ea915180c404;hb=eb96c00343d525921bec628f7455c6227f191ef6;hp=a78fde035df1377b7f994d98a5ea301ca11d8860;hpb=4e7db50d7fb3fd2c7101520f00f0f0b4baf9bddc;p=nonrtric.git diff --git a/policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java b/policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java index a78fde03..92c4bb0a 100644 --- a/policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java +++ b/policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java @@ -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 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); }