openstack/oslo.messaging
Code Issues Proposed changes

rabbit: on reconnect set socket timeout after channel is set

Browse Source 
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
This commit is contained in:
Dmitry Mescheryakov 2016-11-10 14:31:32 +03:00
parent c9b5e474b5
commit 9c25485adb
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -779,9 +779,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('[%(connection_id)s] Reconnected to AMQP server on '
'%(hostname)s:%(port)s via [%(transport)s] client '