X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pmproducer%2Fsrc%2Ftest%2Fjava%2Forg%2Foran%2Fpmproducer%2FIntegrationWithKafka.java;h=27d3170903ca49e93b9120e8c1d5a751a3580354;hb=HEAD;hp=04b501b939c38161f912c2a4c71d6000f1561f86;hpb=fbccee5729fb23f3424046c1d122d29f0fec545a;p=nonrtric%2Fplt%2Franpm.git diff --git a/pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithKafka.java b/pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithKafka.java index 04b501b..27d3170 100644 --- a/pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithKafka.java +++ b/pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithKafka.java @@ -459,8 +459,9 @@ class IntegrationWithKafka { } String msgString = kafkaReceiver.receivedKafkaOutput.valueAsString(); - assertThat(msgString).contains("pmCounterNumber0"); - assertThat(msgString).doesNotContain("pmCounterNumber1"); + assertThat(msgString) + .contains("pmCounterNumber0") + .doesNotContain("pmCounterNumber1"); assertThat(kafkaReceiver.receivedKafkaOutput.getTypeIdFromHeaders()).isEqualTo(PM_TYPE_ID); assertThat(kafkaReceiver.receivedKafkaOutput.getSourceNameFromHeaders()).isEqualTo("HTTPST2-0"); // This is from // the file