|
@@ -95,7 +95,13 @@ class InboundClient:
|
|
self.start()
|
|
self.start()
|
|
else:
|
|
else:
|
|
# threading.Thread(target=self.process_esl_event, args=(e,)).start()
|
|
# threading.Thread(target=self.process_esl_event, args=(e,)).start()
|
|
- self.choose_thread_pool_executor(e).submit(self.process_esl_event, e)
|
|
|
|
|
|
+ # self.choose_thread_pool_executor(e).submit(self.process_esl_event, e)
|
|
|
|
+ try:
|
|
|
|
+ executor = self.choose_thread_pool_executor(e)
|
|
|
|
+ print("Executor obtained:", executor)
|
|
|
|
+ executor.submit(self.process_esl_event, e)
|
|
|
|
+ except Exception as ex:
|
|
|
|
+ print(f"Error occurred while submitting task: {ex}")
|
|
|
|
|
|
def choose_thread_pool_executor(self, e):
|
|
def choose_thread_pool_executor(self, e):
|
|
call_id = EslEventUtil.getCallId(e)
|
|
call_id = EslEventUtil.getCallId(e)
|