1

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

@@ -116,7 +116,7 @@ public class TaskService {
             }
             MqSendLog mqSendLog = msgList.get(i);
             mqSendLogService.updateStatus(mqSendLog.getId(),1,queueName);
-            rabbitMqProducer.sendByWorkQueue(queueName,mqSendLog.getContent());
+            rabbitMqProducer.sendByWorkQueue(queueName,JSONObject.parseObject(mqSendLog.getContent()));
         }
     }