Use threading instead of eventlet for kombu server

Change-Id: I28af31bc7a9c96a621b56a68077710dc3581dcf2
Signed-off-by: Arnaud M <arnaud.morin@gmail.com>
This commit is contained in:
Arnaud M 2024-12-10 00:42:11 +01:00
parent 7d5a1d71aa
commit 451f90e43e

View File

@ -84,7 +84,7 @@ class KombuRPCServer(rpc_base.RPCServer, kombu_base.Base):
"""Return whether server is running."""
return self._running.is_set()
def run(self, executor='eventlet'):
def run(self, executor='threading'):
if self._thread is None:
self._thread = threading.Thread(target=self._run, args=(executor,))
self._thread.daemon = True