1

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

@@ -121,9 +121,8 @@ public class TaskService {
             }
             sendRabbitMq(msgList,mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged() - mqMsg.getMessages_ready(),mqQueueConfig.getQueueName());
         }
-
-        checkDelEcs();
         openEcsList();
+        checkDelEcs();
         delEcsList();
 
     }