From 21d161007120ccebbc4b7cf3f4a9973aeb883e58 Mon Sep 17 00:00:00 2001 From: David TARDIVEL Date: Wed, 6 Jul 2016 17:38:54 +0200 Subject: [PATCH] Update executor to eventlet Default 'blocking' executor handles only one message at once. 'eventlet' executor is recommended. Change-Id: Id738d0462fbb3c7fd6c78ee2f0dd0f1e79131ca7 Closes-Bug: #1517843 --- watcher/common/messaging/messaging_handler.py | 1 + watcher/tests/common/messaging/test_messaging_handler.py | 1 + 2 files changed, 2 insertions(+) diff --git a/watcher/common/messaging/messaging_handler.py b/watcher/common/messaging/messaging_handler.py index 4404222c1..8932a362a 100644 --- a/watcher/common/messaging/messaging_handler.py +++ b/watcher/common/messaging/messaging_handler.py @@ -79,6 +79,7 @@ class MessagingHandler(threading.Thread): def build_server(self, target): return om.get_rpc_server(self.__transport, target, self.__endpoints, + executor='evenlet', serializer=self.__serializer) def _configure(self): diff --git a/watcher/tests/common/messaging/test_messaging_handler.py b/watcher/tests/common/messaging/test_messaging_handler.py index 3e24a78af..683c70f16 100644 --- a/watcher/tests/common/messaging/test_messaging_handler.py +++ b/watcher/tests/common/messaging/test_messaging_handler.py @@ -58,6 +58,7 @@ class TestMessagingHandler(base.TestCase): handler.transport, m_target, [self.ENDPOINT], + executor='evenlet', serializer=None, )