diff --git a/oslo/messaging/_drivers/impl_rabbit.py b/oslo/messaging/_drivers/impl_rabbit.py index 0bc6a8bda..e49834ca9 100644 --- a/oslo/messaging/_drivers/impl_rabbit.py +++ b/oslo/messaging/_drivers/impl_rabbit.py @@ -511,6 +511,7 @@ class Connection(object): self.connection = None self.connection = kombu.connection.BrokerConnection(**params) self.connection_errors = self.connection.connection_errors + self.channel_errors = self.connection.channel_errors if self.memory_transport: # Kludge to speed up tests. self.connection.transport.polling_interval = 0.0 @@ -588,6 +589,9 @@ class Connection(object): except self.connection_errors as e: if error_callback: error_callback(e) + except self.channel_errors as e: + if error_callback: + error_callback(e) except (socket.timeout, IOError) as e: if error_callback: error_callback(e)