|
@@ -103,6 +103,7 @@ public class TaskService {
|
|
|
for (MqQueueConfig mqQueueConfig : queueConfigList) {
|
|
|
List<MqSendLog> msgList = configLogsMap.get(mqQueueConfig.getId());
|
|
|
if(msgList == null || msgList.isEmpty()){
|
|
|
+ log.info("配置config消息为空:{}",mqQueueConfig.getId());
|
|
|
continue;
|
|
|
}
|
|
|
MqMsg mqMsg = mqMsgMap.get(mqQueueConfig.getQueueName());
|