1

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

@@ -193,6 +193,9 @@ 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() -1){
+                continue;
+            }
             MqSendLog mqSendLog = msgList.get(i);
             MqSendLog dbMqSendLog = mqSendLogService.getById(mqSendLog.getId());
             if(dbMqSendLog.getStatus() == 0){