@@ -80,6 +80,8 @@ func (t *MQProc) Process(topic, queuename string, msg *[]byte) {
} else {
global.M2A_LOG.Info("找不到对应KEY的异步任务", zap.Any("key", key), zap.Any("AsyncMap", client.GetAllAsyncTask()))
}
+ } else {
+ global.M2A_LOG.Info("找不到对应的client", zap.Any("sessionId", sessionId))