|
@@ -55,13 +55,15 @@ namespace WingNotificationModule
|
|
|
if (!string.IsNullOrWhiteSpace(msgQueueId) && _notifyExecutorCollection.TryGetValue(msgQueueId, out postMsgExecutor) && postMsgExecutor != null)
|
|
|
{
|
|
|
postMsgExecutor.Add(_sendMessage, messageParam);
|
|
|
- Logger.WriteLineInfo($"postMsgExecutor.Add,msgQueueId:{msgQueueId},Token:{messageParam.Token},WSConnectType:{messageParam.WSConnectType},Message:{messageParam.Message}");
|
|
|
+ Logger.WriteLineInfo($"postMsgExecutor.Add,, WorkerCount:{postMsgExecutor.WorkerCount},GetExecutingStatus:{postMsgExecutor.GetExecutingStatus},IsClosed:{postMsgExecutor.IsClosed},msgQueueId:{msgQueueId},Token:{messageParam.Token},WSConnectType:{messageParam.WSConnectType},Message:{messageParam.Message}");
|
|
|
}
|
|
|
else if (_notifyExecutorCollection.TryGetValue(DefaultMessageQueueId, out postMsgExecutor) && postMsgExecutor != null)
|
|
|
{
|
|
|
postMsgExecutor.Add(_sendMessage, messageParam);
|
|
|
- Logger.WriteLineInfo($"postMsgExecutor.Add,msgQueueId:{msgQueueId},Token:{messageParam.Token},WSConnectType:{messageParam.WSConnectType},Message:{messageParam.Message}");
|
|
|
+ Logger.WriteLineInfo($"postMsgExecutor.Add, WorkerCount:{postMsgExecutor.WorkerCount},GetExecutingStatus:{postMsgExecutor.GetExecutingStatus},IsClosed:{postMsgExecutor.IsClosed},msgQueueId:{msgQueueId},Token:{messageParam.Token},WSConnectType:{messageParam.WSConnectType},Message:{messageParam.Message}");
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
}
|