1

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

@@ -193,9 +193,6 @@ public class TaskService {
 
     private synchronized void sendRabbitMq(List<MqSendLog> msgList, Integer msgCount,String queueName) {
         for (int i = 0;i < msgCount ;i++){
-            if(i > msgList.size() ){
-                continue;
-            }
             MqSendLog mqSendLog = msgList.get(i);
             MqSendLog dbMqSendLog = mqSendLogService.getById(mqSendLog.getId());
             if(dbMqSendLog.getStatus() == 0){