New O1 tests for python SDK

[it/dep.git] / smo-install / test / pythonsdk / src / oransdk / dmaap / dmaap.py

diff --git a/smo-install/test/pythonsdk/src/oransdk/dmaap/dmaap.py b/smo-install/test/pythonsdk/src/oransdk/dmaap/dmaap.py
index 6affd4e..52eac7d 100644 (file)
--- a/smo-install/test/pythonsdk/src/oransdk/dmaap/dmaap.py
+++ b/smo-install/test/pythonsdk/src/oransdk/dmaap/dmaap.py
@@ -55,6 +55,19 @@ class OranDmaap(Dmaap):
         """
         OranDmaap._send_event("unauthenticated.SEC_FAULT_OUTPUT", event, "Send link failure event")
 
+    @classmethod
+    def get_message_from_topic(cls, topic, timeout, dmaap_group, dmaap_user) -> str:
+        """
+        Get payload from any topic.
+
+        Returns:
+            the result
+
+        """
+        url = f"{cls.base_url}/events/{topic}/{dmaap_group}/{dmaap_user}?timeout={timeout}"
+        return cls.send_message('GET',
+                                  'Get payload of specific topic', url)
+
     @classmethod
     def get_result(cls) -> str:
         """