diff --git a/tfw/internals/networking/zmq_listener.py b/tfw/internals/networking/zmq_listener.py index a46fb5a..a1e1313 100644 --- a/tfw/internals/networking/zmq_listener.py +++ b/tfw/internals/networking/zmq_listener.py @@ -12,8 +12,8 @@ class ZMQDownlinkListener: def __init__(self, bind_addr): self._zmq_pull_socket = zmq.Context.instance().socket(zmq.PULL) self._zmq_pull_socket.setsockopt(zmq.RCVHWM, 0) - self._zmq_pull_stream = ZMQStream(self._zmq_pull_socket) self._zmq_pull_socket.bind(bind_addr) + self._zmq_pull_stream = ZMQStream(self._zmq_pull_socket) LOG.debug('Pull socket bound to %s', bind_addr) def register_callback(self, callback):