commit a926d94469780de763da510c9cc01b768df2e444
author Bartosz Gardziejewski <bartosz.gardziejewski@nokia.com> Wed Jul 29 11:13:36 2020 +0200
committer Bartosz Gardziejewski <bartosz.gardziejewski@nokia.com> Wed Jul 29 12:19:21 2020 +0200
tree 1f25b961784672c3f1f7ac71f2829743fcbc8e41
parent 7a51eafe2231b2719cb842e6407ce3178d617268

Add topic validation for dcaegen2 VES tests

Issue-ID: DCAEGEN2-1771
Signed-off-by: Bartosz Gardziejewski <bartosz.gardziejewski@nokia.com>
Change-Id: Ifb4f0f01ef3dcda366147d32c98a9be7890b6f56

tests/dcaegen2/testcases/resources/DcaeLibrary.py

diff --git a/tests/dcaegen2/testcases/resources/DcaeLibrary.py b/tests/dcaegen2/testcases/resources/DcaeLibrary.py
index 6b96826..a9d5def 100644
--- a/tests/dcaegen2/testcases/resources/DcaeLibrary.py
+++ b/tests/dcaegen2/testcases/resources/DcaeLibrary.py
@@ -88,6 +88,18 @@
         return
 
     @staticmethod
+    def dmaap_message_receive_on_topic(evtobj, topic):
+
+        evt_str = DMaaP.deque_event()
+        while evt_str != None:
+            if evtobj in evt_str and topic in evt_str:
+                logger.info("DMaaP Receive Expected Publish Event:\n" + evt_str)
+                logger.info("On Expected Topic:\n" + topic)
+                return 'true'
+            evt_str = DMaaP.deque_event()
+        return 'false'
+
+    @staticmethod
     def dmaap_message_receive(evtobj, action='contain'):
         
         evt_str = DMaaP.deque_event()