Adjusted threadpool for heavy clusters.

Author: karel26

services/servicebus/service.py

@@ -67,7 +67,8 @@ async def start(self):
         await super().start()
         try:
             # Start the DCS listener
-            self.executor = ThreadPoolExecutor(thread_name_prefix='ServiceBus', max_workers=100)
+            self.executor = ThreadPoolExecutor(thread_name_prefix='ServiceBus',
+                                               max_workers=100 if self.master else 20)
             await self.start_udp_listener()
 
             # cleanup the intercom and broadcast channels