|
@@ -338,8 +338,8 @@ public class TaskService {
|
|
|
List<MqSendLog> mqSendLogs = configLogsMap.get(mqQueueConfig.getId());
|
|
|
MqMsg mqMsg = mqMsgMap.get(mqEcs.getQueueName());
|
|
|
Integer notModelingCount = mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged() - mqMsg.getMessages_ready();
|
|
|
- if(mqSendLogs.size() - notModelingCount + mqQueueConfig.getScalingThreshold() >0 ){
|
|
|
- log.info("待计算数量:{}大于空闲服务数量:{},不关闭",mqSendLogs.size(),notModelingCount);
|
|
|
+ if(mqSendLogs.size() - (notModelingCount + mqQueueConfig.getScalingThreshold()) >0 ){
|
|
|
+ log.info("待计算数量:{}大于空闲服务数量:{},阈值{},不关闭",mqSendLogs.size(),notModelingCount,mqQueueConfig.getScalingThreshold());
|
|
|
continue;
|
|
|
}
|
|
|
log.info("checkDelEcs-实例开启{}时间大于{}分钟,开始关闭:{}",between,mqQueueConfig.getStopScalingTime(),mqEcs.getEcsName());
|