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=5db57e7bc404bb5a8cd2d2aeaf4940782e75f434;hpb=3483a78c55f1830dd0aa28f789ddf817ea1358c0;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 5db57e7b..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
@@ -131,12 +131,12 @@ class DmaapMessageConsumerTest {
         when(messageRouterConsumerMock.getForEntity(any())).thenReturn(response);
 
         final ListAppender<ILoggingEvent> logAppender =
-                LoggingUtils.getLogListAppender(DmaapMessageConsumer.class, WARN);
+            LoggingUtils.getLogListAppender(DmaapMessageConsumer.class, WARN);
 
         messageConsumerUnderTest.start().join();
 
         assertThat(logAppender.list.get(0).getFormattedMessage())
-                .isEqualTo("Cannot fetch because of Error respons: 400 BAD_REQUEST Error");
+            .isEqualTo("Cannot fetch because of Error respons: 400 BAD_REQUEST Error");
 
         verify(messageConsumerUnderTest).sleep(DmaapMessageConsumer.TIME_BETWEEN_DMAAP_RETRIES);
     }
@@ -148,15 +148,15 @@ class DmaapMessageConsumerTest {
         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\"}";
+            + "\"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();