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=6e7865689d11304c59afdc0462e31ea50a7f33a3;hb=d9df6244e4ba89b71cba364f156ca529c3703faa;hp=5c11830068c2853ac3d9efa90f4e6d83e03dfdf6;hpb=144374e691c0f1bdcd90cf7c01de263c905d45b7;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 5c118300..6e786568 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
@@ -145,9 +145,8 @@ class DmaapMessageConsumerTest {
 
         messageConsumerUnderTest.start().join();
 
-        assertThat(logAppender.list.toString()
-            .contains("Cannot fetch because of Error respons " + responseCode + " " + responseMessage + " from DMaaP."))
-                .isTrue();
+        assertThat(logAppender.list.get(0).getFormattedMessage()).isEqualTo(
+            "Cannot fetch because of Error respons " + responseCode + " " + responseMessage + " from DMaaP.");
 
         verify(messageConsumerUnderTest).sleep(DmaapMessageConsumer.TIME_BETWEEN_DMAAP_RETRIES);
     }