openstack
/
oslo.messaging
Code Issues Proposed changes

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

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
Show Stats 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)
log_info['sleep_time'] = sleep_time
LOG.error(_('AMQP server on %(hostname)s:%(port)d is '
'unreachable: %(err_str)s. Trying again in '
'%(sleep_time)d seconds.') % log_info)
if 'Socket closed' in six.text_type(e):
LOG.error(_('AMQP server %(hostname)s:%(port)d closed'
' 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)
def ensure(self, error_callback, method, retry=None):