We were missing some wrapping around when consumers are declared and
a case where we had an exception we weren't trapping. In the latter
case, it's not easy to trap it because you'd have to bypass the kombu
interface and import amqplib and try to trap one of its exceptions.
What I've implemented here looks for 'timeout' in any exception, even
though I really don't like it. :)
Reviewed: https:/ /review. openstack. org/2973 github. com/openstack/ nova/commit/ 59e8ae1362f33ab 30b2dc900dcbde3 0efc5a57c8
Committed: http://
Submitter: Jenkins
Branch: master
commit 59e8ae1362f33ab 30b2dc900dcbde3 0efc5a57c8
Author: Chris Behrens <email address hidden>
Date: Wed Jan 11 12:35:42 2012 -0800
Implement more complete kombu reconnecting
Fixes bug 888621
We were missing some wrapping around when consumers are declared and
a case where we had an exception we weren't trapping. In the latter
case, it's not easy to trap it because you'd have to bypass the kombu
interface and import amqplib and try to trap one of its exceptions.
What I've implemented here looks for 'timeout' in any exception, even
though I really don't like it. :)
Fixes HACKING violations while I'm at it.
Change-Id: I0132fbc4377e22 1b0a366d0340652 147ddb33c87