diff --git a/shared/messaging/messaging/router.py b/shared/messaging/messaging/router.py index 844321e54e6dc84280bc21bbc1fe6b57d6aac4cc..f075a5b1870cf89dbacebe45407448c77640b6a9 100644 --- a/shared/messaging/messaging/router.py +++ b/shared/messaging/messaging/router.py @@ -109,8 +109,12 @@ class Router(MessageReceiverIF): for pattern, callbacks in self.callbacks.items(): # Convert hashable str version of pattern back to dict dict_pattern = json.loads(pattern) - msg = message['type'] if hasattr(message, 'type') else message['application'] - logger.debug(f"\nRouter.receive_message > pattern: {dict_pattern}, message: {msg}, matches: {self.matches(pattern, message)}\n") + msg_recd = message["type"] if "type" in message.keys() else message["application"] + + logger.debug( + f">>> Router.receive_message > pattern: {dict_pattern}, message: {msg_recd}, matches:" + f" {self.matches(pattern, message)}\n" + ) if self.matches(dict_pattern, message): # print(f"Router.receive_message> pattern {pattern} matches with message {message}") diff --git a/shared/messaging/setup.py b/shared/messaging/setup.py index dba01bff3ed1c9248d95c21a6185fcb49e019b72..fb39e2882d5fb9b700608d197656f9447f08bb40 100644 --- a/shared/messaging/setup.py +++ b/shared/messaging/setup.py @@ -18,6 +18,7 @@ setup( url="TBD", license="GPL", install_requires=["kombu", "pycapo"], + requires=["kombu", "pycapo"], keywords=[], packages=["messaging"], classifiers=["Programming Language :: Python :: 3.8"],