Until fully understood, I'm trying next hack to avoid indefinite retry loop.
[root@rhos5-node3 ~]# diff -u /usr/lib/python2.7/site-packages/neutron/openstack/common/rpc/impl_kombu.py.orig /usr/lib/python2.7/site-packages/neutron/openstack/common/rpc/impl_kombu.py --- /usr/lib/python2.7/site-packages/neutron/openstack/common/rpc/impl_kombu.py.orig 2014-11-18 12:30:53.365256421 +0100 +++ /usr/lib/python2.7/site-packages/neutron/openstack/common/rpc/impl_kombu.py 2014-11-18 12:48:26.371730454 +0100 @@ -746,6 +746,12 @@ self.consume() except greenlet.GreenletExit: return + except ChannelError as ce: + if ce.amqp_reply_code == 404: + LOG.error(_LE("Discarded ChannelError exception: %s"), ce) + else: + raise ce + if self.consumer_thread is None: self.consumer_thread = eventlet.spawn(_consumer_thread) return self.consumer_thread
Until fully understood, I'm trying next hack to avoid indefinite retry loop.
[root@rhos5-node3 ~]# diff -u /usr/lib/ python2. 7/site- packages/ neutron/ openstack/ common/ rpc/impl_ kombu.py. orig /usr/lib/ python2. 7/site- packages/ neutron/ openstack/ common/ rpc/impl_ kombu.py python2. 7/site- packages/ neutron/ openstack/ common/ rpc/impl_ kombu.py. orig 2014-11-18 12:30:53.365256421 +0100 python2. 7/site- packages/ neutron/ openstack/ common/ rpc/impl_ kombu.py 2014-11-18 12:48:26.371730454 +0100
self. consume( ) GreenletExit:
return _LE("Discarded ChannelError exception: %s"), ce) thread is None:
self. consumer_ thread = eventlet. spawn(_ consumer_ thread) thread
--- /usr/lib/
+++ /usr/lib/
@@ -746,6 +746,12 @@
except greenlet.
+ except ChannelError as ce:
+ if ce.amqp_reply_code == 404:
+ LOG.error(
+ else:
+ raise ce
+
if self.consumer_
return self.consumer_