diff --git a/monkey/monkey_island/cc/event_queue/pypubsub_island_event_queue.py b/monkey/monkey_island/cc/event_queue/pypubsub_island_event_queue.py index 55d4f9846..3cf1399c9 100644 --- a/monkey/monkey_island/cc/event_queue/pypubsub_island_event_queue.py +++ b/monkey/monkey_island/cc/event_queue/pypubsub_island_event_queue.py @@ -12,17 +12,17 @@ logger = logging.getLogger(__name__) class PyPubSubIslandEventQueue(IIslandEventQueue): def __init__(self, pypubsub_publisher: Publisher): - self._pypubsub_publisher_wrapped = PyPubSubPublisherWrapper(pypubsub_publisher) + self._pypubsub_publisher_wrapper = PyPubSubPublisherWrapper(pypubsub_publisher) def subscribe(self, topic: IslandEventTopic, subscriber: IslandEventSubscriber): topic_name = topic.name # needs to be a string for pypubsub - self._pypubsub_publisher_wrapped.subscribe(topic_name, subscriber) + self._pypubsub_publisher_wrapper.subscribe(topic_name, subscriber) def publish(self, topic: IslandEventTopic, event: Any = None): topic_name = topic.name # needs to be a string for pypubsub logger.debug(f"Publishing {topic_name} event") if event is None: - self._pypubsub_publisher_wrapped.publish(topic_name) + self._pypubsub_publisher_wrapper.publish(topic_name) else: - self._pypubsub_publisher_wrapped.publish(topic_name, event=event) + self._pypubsub_publisher_wrapper.publish(topic_name, event=event)