|
@@ -253,7 +253,7 @@ public class TaskService {
|
|
|
|
|
|
Integer ecsCount = countMap.get(mqQueueConfig.getQueueName());
|
|
|
MqMsg mqMsg = mqMsgMap.get(mqQueueConfig.getQueueName());
|
|
|
- Boolean flag = mqQueueConfig.getOpenScalingTime() == 0 || checkOpenCount % mqQueueConfig.getOpenScalingTime() * 2 == 0;
|
|
|
+ Boolean flag = mqQueueConfig.getOpenScalingTime() == 0 || checkOpenCount % (mqQueueConfig.getOpenScalingTime() * 2) == 0;
|
|
|
//未在计算的服务器数量
|
|
|
Integer noModelingCount = mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged();
|
|
|
//未启动的服务器数量
|