设置打包时可以通过ＧＩＴ查看源码

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/QueueService.java

@@ -7,6 +7,7 @@ import com.yanzuoguang.util.vo.PageSizeData;
 
 /**
  * 队列服务
+ *
  * @author 颜佐光
  */
 public interface QueueService {
@@ -15,6 +16,5 @@ public interface QueueService {
      *
      * @param req 保存队列服务
      */
-    void
-    create(QueueVo req);
+    void create(QueueVo req);
 }

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java

@@ -317,12 +317,14 @@ public class MqServiceImpl implements MqService {
 
         // 发送消息，等待下次重新发送
         req.addPos();
-        String json = JsonHelper.serialize(req);
         if (sendQueueName.isEmpty()) {
+            String json = JsonHelper.serialize(req);
             return this.message(new MessageVo(req.getQueueName(), req.getQueueName(), json, req.getNextDelayTime()));
         } else {
             String ret = StringHelper.EMPTY;
             for (String name : sendQueueName) {
+                req.setToken(name);
+                String json = JsonHelper.serialize(req);
                 ret = this.message(new MessageVo(name, name, json));
             }
             return ret;