diff options
| author | Eric Windisch <eric@cloudscaling.com> | 2013-06-19 14:35:11 -0400 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-07-23 17:40:56 +0000 |
| commit | a047a353438d1e9449f94850b29d79bb2dd8f9b1 (patch) | |
| tree | 8c38750dbc9a13bd246bc95ce7f08d685c90f8de /openstack/common | |
| parent | 8418dd3fba2f6f3ca4c635a26eeb61fd37d05f86 (diff) | |
| download | oslo-a047a353438d1e9449f94850b29d79bb2dd8f9b1.tar.gz oslo-a047a353438d1e9449f94850b29d79bb2dd8f9b1.tar.xz oslo-a047a353438d1e9449f94850b29d79bb2dd8f9b1.zip | |
Make ZeroMQ based RPC consumer threads more robust
Consumers could potentially raise an uncaught exception
and exit prematurely.
Related to bug 1189711
Change-Id: I9cb32d8530f3a1dd623e193476e02b990b40b466
Diffstat (limited to 'openstack/common')
| -rw-r--r-- | openstack/common/rpc/impl_zmq.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/openstack/common/rpc/impl_zmq.py b/openstack/common/rpc/impl_zmq.py index 33d5cb6..a5ddccf 100644 --- a/openstack/common/rpc/impl_zmq.py +++ b/openstack/common/rpc/impl_zmq.py @@ -383,6 +383,7 @@ class ZmqBaseReactor(ConsumerBase): LOG.info(_("In reactor registered")) def consume_in_thread(self): + @excutils.forever_retry_uncaught_exceptions def _consume(sock): LOG.info(_("Consuming socket")) while True: |