1

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

@@ -62,6 +62,10 @@ public class TaskService {
         //设置分配队列
         HashSet<String> numList  = new HashSet<>();
         for (MqSendLog mqSendLog : mqSendLogs) {
+            if(StringUtils.isBlank(mqSendLog.getContent())){
+                mqSendLogService.updateStatus(mqSendLog.getId(),2,null);
+                continue;
+            }
             Integer configId = scenePlusService.getQueueConfig(mqSendLog);
             if(numList.contains(mqSendLog.getNum())){
                 mqSendLogService.updateStatus(mqSendLog.getId(),2,null);