From a047a353438d1e9449f94850b29d79bb2dd8f9b1 Mon Sep 17 00:00:00 2001
From: Eric Windisch <eric@cloudscaling.com>
Date: Wed, 19 Jun 2013 14:35:11 -0400
Subject: 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
---
 openstack/common/rpc/impl_zmq.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'openstack')

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:
-- 
cgit