|
@@ -272,7 +272,7 @@ public class TaskService {
|
|
|
MqQueueConfig mqQueueConfig = queueMap.get(key);
|
|
|
List<MqSendLog> msgList = configLogsMap.get(mqQueueConfig.getId());
|
|
|
if(msgList.isEmpty()){
|
|
|
- log.info("openEcsList--待推送消息数为0,无需开启:{}",take.getQueueName());
|
|
|
+ log.info("openEcsList--待推送消息数为0,无需开启:{},{}",key,take.getQueueName());
|
|
|
continue;
|
|
|
}
|
|
|
countMap.merge(mqQueueConfig.getQueueName(), 1, Integer::sum);
|