From b16d19e0ed856e204ee72e36f0c7a402bddc6a68 Mon Sep 17 00:00:00 2001 From: Mike Salvatore Date: Tue, 6 Sep 2022 15:00:24 -0400 Subject: [PATCH] Common: Rename _pypubsub_publisher_wrappe{d,r} --- monkey/common/event_queue/pypubsub_agent_event_queue.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/monkey/common/event_queue/pypubsub_agent_event_queue.py b/monkey/common/event_queue/pypubsub_agent_event_queue.py index cf75c5b6a..246b743d1 100644 --- a/monkey/common/event_queue/pypubsub_agent_event_queue.py +++ b/monkey/common/event_queue/pypubsub_agent_event_queue.py @@ -15,7 +15,7 @@ logger = logging.getLogger(__name__) class PyPubSubAgentEventQueue(IAgentEventQueue): def __init__(self, pypubsub_publisher: Publisher): - self._pypubsub_publisher_wrapped = PyPubSubPublisherWrapper(pypubsub_publisher) + self._pypubsub_publisher_wrapper = PyPubSubPublisherWrapper(pypubsub_publisher) def subscribe_all_events(self, subscriber: AgentEventSubscriber): self._subscribe(_ALL_EVENTS_TOPIC, subscriber) @@ -32,7 +32,7 @@ class PyPubSubAgentEventQueue(IAgentEventQueue): self._subscribe(tag_topic, subscriber) def _subscribe(self, topic: str, subscriber: AgentEventSubscriber): - self._pypubsub_publisher_wrapped.subscribe(topic, subscriber) + self._pypubsub_publisher_wrapper.subscribe(topic, subscriber) def publish(self, event: AbstractAgentEvent): self._publish_to_all_events_topic(event) @@ -53,7 +53,7 @@ class PyPubSubAgentEventQueue(IAgentEventQueue): def _publish_event(self, topic: str, event: AbstractAgentEvent): logger.debug(f"Publishing a {event.__class__.__name__} event to {topic}") - self._pypubsub_publisher_wrapped.publish(topic, event=event) + self._pypubsub_publisher_wrapper.publish(topic, event=event) # Appending a unique string to the topics for type and tags prevents bugs caused by collisions # between type names and tag names.