|
@@ -74,6 +74,7 @@ public class TaskService {
|
|
List<MqSendLog> panoList = mqSendLogs.stream().filter(e -> "pano".equals(e.getType())).collect(Collectors.toList());
|
|
List<MqSendLog> panoList = mqSendLogs.stream().filter(e -> "pano".equals(e.getType())).collect(Collectors.toList());
|
|
List<MqQueueConfig> queueConfigList = queueConfigService.list();
|
|
List<MqQueueConfig> queueConfigList = queueConfigService.list();
|
|
rabbitMqService.getMqMsgMap(queueConfigList);
|
|
rabbitMqService.getMqMsgMap(queueConfigList);
|
|
|
|
+
|
|
if(!fdkkList.isEmpty()){
|
|
if(!fdkkList.isEmpty()){
|
|
sendMqByType(fdkkList,"4dkk");
|
|
sendMqByType(fdkkList,"4dkk");
|
|
}
|
|
}
|