Skip to content
Snippets Groups Projects

Workflow parse delivery json

Merged Daniel Lyons requested to merge workflow-parse-delivery-json into main
1 file
+ 2
2
Compare changes
  • Side-by-side
  • Inline
@@ -86,14 +86,14 @@ class Router(MessageReceiverIF):
:param message: Received message
"""
if self.service == "capability":
logger.info(f"receiving message: {message}")
logger.debug(f"receiving message: {message}")
message = json.loads(message)
for pattern, callbacks in self.callbacks.items():
# Convert hashable str version of pattern back to dict
dict_pattern = json.loads(pattern)
logger.info(
logger.debug(
f"\nRouter.receive_message > pattern: {dict_pattern}, message: {message['type']}, matches: {self.matches(pattern, message)}\n"
)
if self.matches(dict_pattern, message):
Loading