X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=smo-install%2Ftest%2Fpythonsdk%2Fsrc%2Foransdk%2Fdmaap%2Fdmaap.py;h=52eac7d5dbb30271dc4d7d07002a3fb5453aa437;hb=0eb37372a837a16225f5788895638b00da52ce43;hp=6affd4eae2d5c5d3232a5d5d3b3ddcd83de68485;hpb=5592b6267f4801163873f8fd734c9ab9adb2f368;p=it%2Fdep.git

diff --git a/smo-install/test/pythonsdk/src/oransdk/dmaap/dmaap.py b/smo-install/test/pythonsdk/src/oransdk/dmaap/dmaap.py
index 6affd4ea..52eac7d5 100644
--- 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:
         """