diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-06-26 11:40:23 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-06-26 11:40:23 +0000 |
| commit | 891287451754ac0394f1b8fa31a0505a304dccc2 (patch) | |
| tree | 9fa50b44acbf26731cee1e2c520bc7c5f2451c6c /openstack/common/rpc/impl_qpid.py | |
| parent | 18dc396748114e5d8af0a9f84ba944e532815b65 (diff) | |
| parent | 22ec8ff616a799085239e3e529daeeefea6366c4 (diff) | |
| download | oslo-891287451754ac0394f1b8fa31a0505a304dccc2.tar.gz oslo-891287451754ac0394f1b8fa31a0505a304dccc2.tar.xz oslo-891287451754ac0394f1b8fa31a0505a304dccc2.zip | |
Merge "Make AMQP based RPC consumer threads more robust"
Diffstat (limited to 'openstack/common/rpc/impl_qpid.py')
| -rw-r--r-- | openstack/common/rpc/impl_qpid.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/openstack/common/rpc/impl_qpid.py b/openstack/common/rpc/impl_qpid.py index 46dcb6a..6fa9be4 100644 --- a/openstack/common/rpc/impl_qpid.py +++ b/openstack/common/rpc/impl_qpid.py @@ -24,6 +24,7 @@ import eventlet import greenlet from oslo.config import cfg +from openstack.common import excutils from openstack.common.gettextutils import _ from openstack.common import importutils from openstack.common import jsonutils @@ -576,6 +577,7 @@ class Connection(object): def consume_in_thread(self): """Consumer from all queues/consumers in a greenthread.""" + @excutils.forever_retry_uncaught_exceptions def _consumer_thread(): try: self.consume() |