-
class watcher.common.messaging.messaging_handler.MessagingHandler(publisher_id, topic_name, endpoints, version, serializer=None)[source]
Bases: threading.Thread
-
add_endpoints(endpoints)[source]
-
build_notifier()[source]
-
build_server(target)[source]
-
publish_event(event_type, payload, request_id=None)[source]
-
remove_endpoint(endpoint)[source]
-
run()[source]
-
stop()[source]