全景看看

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

@@ -327,7 +327,7 @@ public class TaskService {
                 }
                 log.info("mq消息信息：{},{}",mqEcs.getQueueName(),mqMsg);
                 Integer notModelingCount = mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged() - mqMsg.getMessages_ready();
-                if(mqSize >0 && mqSize - (notModelingCount + mqQueueConfig.getScalingThreshold()) >0 ){
+                if( mqSize - (notModelingCount + mqQueueConfig.getScalingThreshold()) >0 ){
                     log.info("待计算数量:{}大于空闲服务数量:{},阈值{}，不关闭",mqSize,notModelingCount,mqQueueConfig.getScalingThreshold());
                     continue;
                 }