diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index c001ae4c8..036bbd0d8 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -988,7 +988,8 @@ class Connection(object): self.connection.drain_events(timeout=0.001) except socket.timeout: pass - except kombu.exceptions.OperationalError as exc: + except (socket.timeout, + kombu.exceptions.OperationalError) as exc: LOG.info(_LI("A recoverable connection/channel error " "occurred, trying to reconnect: %s"), exc) self.ensure_connection()