And here is stack trace to help in dealing with errors:
NOTE that I am running amqp 2.0 and Kombu 4.0.2 with oslo_messaging.
This seems to be a small issue in oslo_messaging not dealing with this type of error.
It's the only issue I've encountered so far after running this for some time.
ERROR 2017-03-02 02:00:36,652 excutils:262 wrapper Unexpected exception occurred 60 time(s)... retrying.
Traceback (most recent call last):
File "[..]/virtualenv/lib/python2.7/site-packages/oslo_utils/excutils.py", line 250, in wrapper
return infunc(*args, **kwargs)
File "[..]/virtualenv/lib/python2.7/site-packages/oslo_messaging/_drivers/base.py", line 302, in _runner
batch_size=self.batch_size, batch_timeout=self.batch_timeout)
File "[..]/virtualenv/lib/python2.7/site-packages/oslo_messaging/_drivers/base.py", line 52, in wrapper
msg = func(in_self, timeout=timeout_watch.leftover(True))
File "[..]/virtualenv/lib/python2.7/site-packages/oslo_messaging/_drivers/amqpdriver.py", line 211, in poll
self.conn.consume(timeout=timeout)
File "[..]/virtualenv/lib/python2.7/site-packages/oslo_messaging/_drivers/impl_rabbit.py", line 1098, in consume
error_callback=_error_callback)
File "[..]/virtualenv/lib/python2.7/site-packages/oslo_messaging/_drivers/impl_rabbit.py", line 817, in ensure
ret, channel = autoretry_method()
File "[..]/virtualenv/lib/python2.7/site-packages/kombu/connection.py", line 507, in _ensured
errback and errback(exc, 0)
File "[..]/virtualenv/lib/python2.7/site-packages/oslo_messaging/_drivers/impl_rabbit.py", line 750, in on_error
info.update(self._get_connection_info())
File "[..]/virtualenv/lib/python2.7/site-packages/oslo_messaging/_drivers/impl_rabbit.py", line 1176, in _get_connection_info
client_port = self.channel.connection.sock.getsockname()[1]
AttributeError: 'NoneType' object has no attribute 'getsockname'
ERROR 2017-03-02 02:00:37,658 impl_rabbit:1063 _error_callback Failed to consume message from queue: 'NoneType' object has no attribute 'getsockname'
And here is stack trace to help in dealing with errors:
NOTE that I am running amqp 2.0 and Kombu 4.0.2 with oslo_messaging.
This seems to be a small issue in oslo_messaging not dealing with this type of error.
It's the only issue I've encountered so far after running this for some time.
ERROR 2017-03-02 02:00:36,652 excutils:262 wrapper Unexpected exception occurred 60 time(s)... retrying. v/lib/python2. 7/site- packages/ oslo_utils/ excutils. py", line 250, in wrapper v/lib/python2. 7/site- packages/ oslo_messaging/ _drivers/ base.py" , line 302, in _runner size=self. batch_size, batch_timeout= self.batch_ timeout) v/lib/python2. 7/site- packages/ oslo_messaging/ _drivers/ base.py" , line 52, in wrapper timeout_ watch.leftover( True)) v/lib/python2. 7/site- packages/ oslo_messaging/ _drivers/ amqpdriver. py", line 211, in poll conn.consume( timeout= timeout) v/lib/python2. 7/site- packages/ oslo_messaging/ _drivers/ impl_rabbit. py", line 1098, in consume callback= _error_ callback) v/lib/python2. 7/site- packages/ oslo_messaging/ _drivers/ impl_rabbit. py", line 817, in ensure v/lib/python2. 7/site- packages/ kombu/connectio n.py", line 507, in _ensured v/lib/python2. 7/site- packages/ oslo_messaging/ _drivers/ impl_rabbit. py", line 750, in on_error update( self._get_ connection_ info()) v/lib/python2. 7/site- packages/ oslo_messaging/ _drivers/ impl_rabbit. py", line 1176, in _get_connection _info connection. sock.getsocknam e()[1]
Traceback (most recent call last):
File "[..]/virtualen
return infunc(*args, **kwargs)
File "[..]/virtualen
batch_
File "[..]/virtualen
msg = func(in_self, timeout=
File "[..]/virtualen
self.
File "[..]/virtualen
error_
File "[..]/virtualen
ret, channel = autoretry_method()
File "[..]/virtualen
errback and errback(exc, 0)
File "[..]/virtualen
info.
File "[..]/virtualen
client_port = self.channel.
AttributeError: 'NoneType' object has no attribute 'getsockname'
ERROR 2017-03-02 02:00:37,658 impl_rabbit:1063 _error_callback Failed to consume message from queue: 'NoneType' object has no attribute 'getsockname'