X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-adaptor-java%2Fsrc%2Ftest%2Fjava%2Forg%2Foran%2Fdmaapadapter%2FConsumerController.java;h=70e89d6bfa582f57ce19f54d514106382faac091;hb=0f6367023720ecc7d7b4b38cbbc4282792172a89;hp=4b6d9010b1ec32121118e42326f277fe31878623;hpb=960e66a1728c1c332f6b74320bbd086a442ba5ea;p=nonrtric.git

diff --git a/dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/ConsumerController.java b/dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/ConsumerController.java
index 4b6d9010..70e89d6b 100644
--- a/dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/ConsumerController.java
+++ b/dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/ConsumerController.java
@@ -56,6 +56,15 @@ public class ConsumerController {
 
         public TestResults() {}
 
+        public boolean hasReceived(String str) {
+            for (String received : receivedBodies) {
+                if (received.equals(str)) {
+                    return true;
+                }
+            }
+            return false;
+        }
+
         public void reset() {
             receivedBodies.clear();
         }