diff options
author | Dmitry Mescheryakov <dmescheryakov@mirantis.com> | 2016-11-10 14:31:32 +0300 |
---|---|---|
committer | Dmitry Mescheryakov (dmitryme) <dmescheryakov@mirantis.com> | 2016-11-10 15:52:02 +0000 |
commit | 6ad4e5c39ef95a2e0bcf3e11938c1793b55957f6 (patch) | |
tree | f1eb8cbcc84c8cba9c32d11232e9e9c5d7989e99 | |
parent | b90580653af33678d9931f33308edee31cf1fe54 (diff) | |
download | oslo-messaging-6ad4e5c39ef95a2e0bcf3e11938c1793b55957f6.tar.gz |
rabbit: on reconnect set socket timeout after channel is set
Currently we set it before the channel and as a result nothing
happens, only an error is logged at the debug level.
Change-Id: Ifebdd957d403e47039c10f7e55c4e7ef08fba658
Closes-Bug: #1640773
(cherry picked from commit 9c25485adb661d44b7f3f0c676ac3705e5754796)
-rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 60461d7..9fb2b7e 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -745,9 +745,8 @@ class Connection(object): """Callback invoked when the kombu reconnects and creates a new channel, we use it the reconfigure our consumers. """ - - self.set_transport_socket_timeout() self._set_current_channel(new_channel) + self.set_transport_socket_timeout() LOG.info(_LI('Reconnected to AMQP server on ' '%(hostname)s:%(port)s via [%(transport)s] client'), |