mq 消息改造

framework-starter/mrxu-starter-rocketmq/src/main/java/com/mrxu/framework/starter/rocketmq/RocketMQSender.java

@@ -26,7 +26,11 @@ public class RocketMQSender {
     private Long messageTimeOut;
 
     public void sendMsg(String topic,String tag,Object body) {
-        rocketMQTemplate.syncSend(topic+":"+tag,new MessageBody(tag,body),messageTimeOut);
+        rocketMQTemplate.syncSend(topic+":"+tag,body,messageTimeOut);
+    }
+
+    public void sendMsg(String topic,MessageBody<Object> body) {
+        rocketMQTemplate.syncSend(topic+":"+body.getTag(),body,messageTimeOut);
     }
 
 /*    *//**