1

src/main/java/com/fdkankan/mqcontroller/service/impl/MqEcsServiceImpl.java

@@ -47,7 +47,6 @@ public class MqEcsServiceImpl extends ServiceImpl<IMqEcsMapper, MqEcs> implement
         LambdaQueryWrapper<MqEcs> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(MqEcs::getIsScaling,1);
         wrapper.eq(MqEcs::getStatus,0);
-        wrapper.isNull(MqEcs::getEcsName);
         wrapper.eq(MqEcs::getQueueName,queueName);
         return this.list(wrapper);
     }

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

@@ -129,6 +129,7 @@ public class TaskService {
             openMap.put(mqQueueConfig.getQueueName(),openList);
         }
         if(msgList.size() + readCount > mqQueueConfig.getScalingThreshold() + list.size() + openList.size() && mqQueueConfig.getOpenScalingTime() % checkOpenCount == 0){
+            log.info("将待开启弹性伸缩放入队列：{}",mqQueueConfig.getQueueName());
             MqScalingConfig mqScalingConfig = mqScalingConfigService.getById(mqQueueConfig.getScalingConfigId());
             DelEcsVo vo = new DelEcsVo(null,mqScalingConfig,mqQueueConfig.getQueueName(),new Date(),msgList);
             openList.offer(vo);