1

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

@@ -246,7 +246,7 @@ public class TaskService {
         Integer noModelingCount = mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged();
         //未启动的服务器数量
         Integer notStartCount = ecsCount - mqMsg.getConsumers();
-        Boolean flag2 = msgList.size()  >  mqQueueConfig.getScalingThreshold() + noModelingCount + notStartCount || (!msgList.isEmpty() &&  noModelingCount + notStartCount == 0 );
+        Boolean flag2 = msgList.size()  >  mqQueueConfig.getScalingThreshold() + noModelingCount + notStartCount || (!msgList.isEmpty() &&  ecsCount + mqMsg.getConsumers() == 0 );
 
         if(flag2 && flag){
             log.info("将待开启弹性伸缩放入队列：{}",mqQueueConfig.getQueueName());