|
|
@@ -106,6 +106,7 @@ class InboundClient:
|
|
|
self.choose_thread_pool_executor(e).submit(self.process_esl_event, e)
|
|
|
|
|
|
def choose_thread_pool_executor(self, e):
|
|
|
+ event_name = EslEventUtil.getEventName(e)
|
|
|
call_id = EslEventUtil.getCallId(e)
|
|
|
device_id = EslEventUtil.getUniqueId(e)
|
|
|
wdh_device_id = EslEventUtil.getDeviceId(e)
|
|
|
@@ -114,7 +115,7 @@ class InboundClient:
|
|
|
random_index = abs(mmh3.hash(random_id)) % len(self.executors)
|
|
|
else:
|
|
|
random_index = random.randint(0, len(self.executors) - 1) if self.executors else 0
|
|
|
- # self.logger.info('choose_thread_pool_executor.index=', random_index, call_id, device_id, wdh_device_id)
|
|
|
+ self.logger.info('choose_thread_pool_executor:event_name=%s, random_index=%s, call_id=%s, unique_id=%s, device_id=%s, ', event_name, random_index, call_id, device_id, wdh_device_id)
|
|
|
return self.executors.get(random_index)
|
|
|
|
|
|
def process_esl_event(self, e):
|
Davidliu