Skip to content
Snippets Groups Projects
Commit 5ffad088 authored by Daniel Lyons's avatar Daniel Lyons
Browse files

Ws 254 messaging bug fix

parent 54b6cb59
No related branches found
No related tags found
1 merge request!303Ws 254 messaging bug fix
Pipeline #1992 passed
......@@ -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}")
......
......@@ -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"],
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment