1

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

@@ -132,7 +132,7 @@ public class TaskService {
                 continue;
             }
             if(mqQueueConfig.getOpenScaling() == 0){    //不开启弹性伸缩
-                if(mqMsg.getMessages_ready() >0){       //待计算队列中有任务
+                if(mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged() - mqMsg.getMessages_ready() <= 0 ){       //待计算队列中有任务
                     continue;
                 }
             }