openstack/deb-python-oslo.messaging
Code Issues Proposed changes

Merge "Add check credentials to log message if rabbmitmq closes socket"

Browse Source
This commit is contained in:
Jenkins
2014-06-17 15:49:30 +00:00
committed by Gerrit Code Review
parent b60a460baf bf281aace5
commit 4d9e250482
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
oslo/messaging/_drivers/impl_rabbit.py
View File

@@ -640,9 +640,14 @@ class Connection(object):
sleep_time = min(sleep_time, self.interval_max) sleep_time = min(sleep_time, self.interval_max)
log_info['sleep_time'] = sleep_time log_info['sleep_time'] = sleep_time
LOG.error(_('AMQP server on %(hostname)s:%(port)d is ' if 'Socket closed' in six.text_type(e):
'unreachable: %(err_str)s. Trying again in ' LOG.error(_('AMQP server %(hostname)s:%(port)d closed'
'%(sleep_time)d seconds.') % log_info) ' the connection. Check login credentials:'
' %(err_str)s') % log_info)
else:
LOG.error(_('AMQP server on %(hostname)s:%(port)d is '
'unreachable: %(err_str)s. Trying again in '
'%(sleep_time)d seconds.') % log_info)
time.sleep(sleep_time) time.sleep(sleep_time)
def ensure(self, error_callback, method, retry=None): def ensure(self, error_callback, method, retry=None):