diff --git a/oslo/messaging/_drivers/impl_rabbit.py b/oslo/messaging/_drivers/impl_rabbit.py index 4df6964b5..515c95a72 100644 --- a/oslo/messaging/_drivers/impl_rabbit.py +++ b/oslo/messaging/_drivers/impl_rabbit.py @@ -514,6 +514,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 @@ -591,6 +592,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)