diff --git a/lib/tfw/networking/event_handlers/server_connector.py b/lib/tfw/networking/event_handlers/server_connector.py index ee4c50e..63f20d0 100644 --- a/lib/tfw/networking/event_handlers/server_connector.py +++ b/lib/tfw/networking/event_handlers/server_connector.py @@ -1,6 +1,5 @@ import zmq from functools import partial -from zmq.eventloop import ioloop from zmq.eventloop.zmqstream import ZMQStream from tfw.networking.serialization import serialize_all @@ -8,9 +7,6 @@ from tfw.config import PUBLISHER_PORT, RECEIVER_PORT from tfw.util import ZMQConnectorBase -ioloop.install() - - class ServerDownlinkConnector(ZMQConnectorBase): def __init__(self, zmq_context=None): super(ServerDownlinkConnector, self).__init__(zmq_context) diff --git a/lib/tfw/networking/server/event_handler_connector.py b/lib/tfw/networking/server/event_handler_connector.py index 276ad9a..4b7240e 100644 --- a/lib/tfw/networking/server/event_handler_connector.py +++ b/lib/tfw/networking/server/event_handler_connector.py @@ -1,5 +1,4 @@ import zmq -from zmq.eventloop import ioloop from zmq.eventloop.zmqstream import ZMQStream from tfw.networking.serialization import serialize_all @@ -9,9 +8,6 @@ log = logging.getLogger(__name__) from tfw.util import ZMQConnectorBase -ioloop.install() - - class EventHandlerDownlinkConnector(ZMQConnectorBase): def __init__(self, zmq_context=None): super(EventHandlerDownlinkConnector, self).__init__(zmq_context)