diff --git a/subscribe/subscribe/__main__.py b/subscribe/subscribe/__main__.py index 52ac0a1..484a395 100644 --- a/subscribe/subscribe/__main__.py +++ b/subscribe/subscribe/__main__.py @@ -7,16 +7,16 @@ class SubscribeClient: @subscribe(topics=["topic1","topic2"]) - def subscribe_multiple_topics(self, payload:dict) -> dict: - return dict + def subscribe_multiple_topics(self, value:str) -> str: + return value @subscribe(topics="topic1") - def subscrib_one_topics(self, payload:dict) -> dict: - return dict + def subscrib_one_topics(self, value:str) -> str: + return value @subscribe(topics="topic.*") - def subscribe_wildcard_topics(self, payload:dict) -> dict: - return dict + def subscribe_wildcard_topics(self, value:str) -> str: + return value def main(): plugin = Plugin( @@ -30,4 +30,4 @@ def main(): if __name__ == "__main__": - main() \ No newline at end of file + main()