diff --git a/src/event_handlers/messaging.py b/src/event_handlers/messaging.py index 2aea906..fd21c92 100644 --- a/src/event_handlers/messaging.py +++ b/src/event_handlers/messaging.py @@ -6,10 +6,11 @@ from zmq.eventloop.zmqstream import ZMQStream from config import PUBLISHER_PORT, RECEIVER_PORT +ioloop.install() + class Messaging: def __init__(self): - ioloop.install() self._zmq_context = zmq.Context.instance() self._zmq_sub_socket = self._zmq_context.socket(zmq.SUB) self._zmq_sub_socket.connect('tcp://localhost:{}'.format(PUBLISHER_PORT))