1

src/main/java/com/fdkankan/mqcontroller/task/TaskService.java

@@ -273,7 +273,7 @@ public class TaskService {
                 List<MqSendLog> msgList = configLogsMap.get(mqQueueConfig.getId());
                 if(msgList.isEmpty()){
                     log.info("openEcsList--待推送消息数为0，无需开启：{}",take.getQueueName());
-                    return;
+                    continue;
                 }
                 countMap.merge(mqQueueConfig.getQueueName(), 1, Integer::sum);
 
@@ -283,7 +283,7 @@ public class TaskService {
                 if(!mqEcsList.isEmpty()){
                     log.info("openEcsList--有启动中的ecs,等待启动完毕执行。。。");
                     openList.offer(take);
-                    return;
+                    continue;
                 }
                 Boolean flag = createEcs( take.getMqScalingConfig());
                 if(flag){