diff --git a/monkey/common/event_queue/i_island_event_queue.py b/monkey/common/event_queue/i_island_event_queue.py index 65eb94ee3..c8e5115a9 100644 --- a/monkey/common/event_queue/i_island_event_queue.py +++ b/monkey/common/event_queue/i_island_event_queue.py @@ -28,12 +28,12 @@ class IIslandEventQueue(ABC): pass @abstractmethod - def publish(self, topic: IslandEventTopic, event_data: Any = None): + def publish(self, topic: IslandEventTopic, event: Any = None): """ Publishes an event topic with the given data :param topic: Event topic to publish - :param event_data: Event data to pass to subscribers with the event publish + :param event: Event to pass to subscribers with the event publish """ pass diff --git a/monkey/common/event_queue/pypubsub_island_event_queue.py b/monkey/common/event_queue/pypubsub_island_event_queue.py index d5d1df7cd..8898b343a 100644 --- a/monkey/common/event_queue/pypubsub_island_event_queue.py +++ b/monkey/common/event_queue/pypubsub_island_event_queue.py @@ -52,7 +52,7 @@ class PyPubSubIslandEventQueue(IIslandEventQueue): # scope. Adding subscribers to self._refs prevents them from ever going out of scope. self._refs.append(subscriber) - def publish(self, topic: IslandEventTopic, event_data: Any = None): + def publish(self, topic: IslandEventTopic, event: Any = None): topic_value = topic.value # needs to be a string for pypubsub logger.debug(f"Publishing {topic_value} event") @@ -61,4 +61,4 @@ class PyPubSubIslandEventQueue(IIslandEventQueue): # otherwise, errors will arise. The MDS of a topic is set when the topic is created, # which in our case is when a subscriber subscribes to a topic (in `subscribe()`) # which is new (hasn't been subscribed to before). - self._pypubsub_publisher.sendMessage(topicName=topic_value, event=event_data) + self._pypubsub_publisher.sendMessage(topicName=topic_value, event=event)