diff options
Diffstat (limited to 'oslo_messaging/_drivers/zmq_driver/poller/threading_poller.py')
| -rw-r--r-- | oslo_messaging/_drivers/zmq_driver/poller/threading_poller.py | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/oslo_messaging/_drivers/zmq_driver/poller/threading_poller.py b/oslo_messaging/_drivers/zmq_driver/poller/threading_poller.py index c6be793..7719310 100644 --- a/oslo_messaging/_drivers/zmq_driver/poller/threading_poller.py +++ b/oslo_messaging/_drivers/zmq_driver/poller/threading_poller.py @@ -42,7 +42,13 @@ class ThreadingPoller(zmq_poller.ZmqPoller): def poll(self, timeout=None): timeout = timeout * 1000 # zmq poller waits milliseconds - sockets = dict(self.poller.poll(timeout=timeout)) + sockets = None + + try: + sockets = dict(self.poller.poll(timeout=timeout)) + except zmq.ZMQError as e: + LOG.debug("Polling terminated with error: %s" % e) + if not sockets: return None, None for socket in sockets: @@ -51,6 +57,12 @@ class ThreadingPoller(zmq_poller.ZmqPoller): else: return socket.recv_multipart(), socket + def resume_polling(self, socket): + pass # Nothing to do for threading poller + + def close(self): + pass # Nothing to do for threading poller + class ThreadingExecutor(zmq_poller.Executor): |