1

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

@@ -198,14 +198,6 @@ public class TaskService {
 
         Integer ecsCount = countMap.get(mqQueueConfig.getQueueName());
         MqMsg mqMsg = mqMsgMap.get(mqQueueConfig.getQueueName());
-        //默认队列
-        if(mqQueueConfig.getIsDefault() == 1 && ecsCount + openList.size()  == 0){
-            log.info("默认队列无服务计算中：{}",mqQueueConfig.getQueueName());
-            MqScalingConfig mqScalingConfig = mqScalingConfigService.getById(mqQueueConfig.getScalingConfigId());
-            DelEcsVo vo = new DelEcsVo(null,mqScalingConfig,mqQueueConfig.getQueueName());
-            openList.offer(vo);
-            return;
-        }
         Boolean flag = mqQueueConfig.getOpenScalingTime() == 0 || checkOpenCount % mqQueueConfig.getOpenScalingTime() == 0;
         //未在计算的服务器数量
         Integer noModelingCount = mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged();