From d151ce12fd6aceb872357a1b4e33463c88f22499 Mon Sep 17 00:00:00 2001 From: Mike Salvatore Date: Wed, 10 Aug 2022 11:33:57 -0400 Subject: [PATCH] Common: Rename _INTERNAL_ALL_EVENT_TYPES_TOPIC -> _ALL_EVENTS_TOPIC --- monkey/common/event_queue/pypubsub_event_queue.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/monkey/common/event_queue/pypubsub_event_queue.py b/monkey/common/event_queue/pypubsub_event_queue.py index 87813311f..bdf292fdd 100644 --- a/monkey/common/event_queue/pypubsub_event_queue.py +++ b/monkey/common/event_queue/pypubsub_event_queue.py @@ -6,7 +6,7 @@ from common.events import AbstractEvent from .i_event_queue import IEventQueue -_INTERNAL_ALL_EVENT_TYPES_TOPIC = "internal_all_event_types" +_ALL_EVENTS_TOPIC = "all_events_topic" class PyPubSubEventQueue(IEventQueue): @@ -14,9 +14,7 @@ class PyPubSubEventQueue(IEventQueue): self._pypubsub_publisher = pypubsub_publisher def subscribe_all_events(self, subscriber: Callable[[AbstractEvent], None]): - self._pypubsub_publisher.subscribe( - listener=subscriber, topicName=_INTERNAL_ALL_EVENT_TYPES_TOPIC - ) + self._pypubsub_publisher.subscribe(listener=subscriber, topicName=_ALL_EVENTS_TOPIC) def subscribe_type( self, event_type: Type[AbstractEvent], subscriber: Callable[[AbstractEvent], None] @@ -35,7 +33,7 @@ class PyPubSubEventQueue(IEventQueue): self._publish_to_tags_topics(event) def _publish_to_all_events_topic(self, event: AbstractEvent): - self._pypubsub_publisher.sendMessage(_INTERNAL_ALL_EVENT_TYPES_TOPIC, event=event) + self._pypubsub_publisher.sendMessage(_ALL_EVENTS_TOPIC, event=event) def _publish_to_type_topic(self, event: AbstractEvent): event_type_topic = PyPubSubEventQueue._get_type_topic(event.__class__)