From f26beb6464485e04c0b972566d89043d750c1efd Mon Sep 17 00:00:00 2001 From: Shreya Malviya Date: Wed, 10 Aug 2022 14:02:53 +0530 Subject: [PATCH] Common: Pass event_data to subscribers when publishing in PyPubSubEventQueue --- monkey/common/event_queue/pypubsub_event_queue.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/monkey/common/event_queue/pypubsub_event_queue.py b/monkey/common/event_queue/pypubsub_event_queue.py index 82bdc9567..ad191fb24 100644 --- a/monkey/common/event_queue/pypubsub_event_queue.py +++ b/monkey/common/event_queue/pypubsub_event_queue.py @@ -32,13 +32,15 @@ class PyPubSubEventQueue(IEventQueue): self._pypubsub_publisher.subscribe(listener=subscriber, topicName=tag) def publish(self, event: AbstractEvent): + event_data = {"event": event} + # publish to event type's topic event_type_name = event.__name__ - self._pypubsub_publisher.sendMessage(event_type_name, event) + self._pypubsub_publisher.sendMessage(event_type_name, **event_data) # publish to all events' topic - self._pypubsub_publisher.sendMessage(INTERNAL_ALL_EVENT_TYPES_TOPIC, event) + self._pypubsub_publisher.sendMessage(INTERNAL_ALL_EVENT_TYPES_TOPIC, **event_data) # publish to tags' topics for tag in event.tags: - self._pypubsub_publisher.sendMessage(tag, event) + self._pypubsub_publisher.sendMessage(tag, **event_data)