diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-08-19 13:01:30 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-08-19 13:01:30 +0000 |
| commit | 1a9966e52d7bf35774b9a009afe6412e6c5f014a (patch) | |
| tree | 9f189a88a85878bed3277805eb56c7dc5fb664b6 /openstack | |
| parent | 3295a9024a9c4e07c8691b047ea32917605d9351 (diff) | |
| parent | a047a353438d1e9449f94850b29d79bb2dd8f9b1 (diff) | |
| download | oslo-1a9966e52d7bf35774b9a009afe6412e6c5f014a.tar.gz oslo-1a9966e52d7bf35774b9a009afe6412e6c5f014a.tar.xz oslo-1a9966e52d7bf35774b9a009afe6412e6c5f014a.zip | |
Merge "Make ZeroMQ based RPC consumer threads more robust"
Diffstat (limited to 'openstack')
| -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: |