1

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

@@ -365,10 +365,16 @@ public class TaskService {
 
             Boolean delFlag = delEcs(take.getMqScalingConfig(), take.getMqEcs().getEcsName());
             if(delFlag){
-                log.info("checkDelEcs--关闭弹性伸缩实例成功：{}", take.getMqEcs().getEcsName());
+                log.info("delEcsList--关闭弹性伸缩实例成功：{}", take.getMqEcs().getEcsName());
                 mqEcsService.updateMqEcs(take.getMqEcs());
             }else {
-                delList.offer(take);
+                List<MqEcs> mqEcsList = mqEcsService.getScalingNotStopList();
+                for (MqEcs mqEcs : mqEcsList) {
+                    if(mqEcs.getEcsName().equals(take.getMqEcs().getEcsName())){
+                        log.info("delEcsList--关闭弹性伸缩实例失败重新尝试：{}", take.getMqEcs().getEcsName());
+                        delList.offer(take);
+                    }
+                }
             }
         }catch (Exception e){
             log.info("delEcsList--关闭弹性伸缩失败:",e);