rocketmq

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

@@ -26,14 +26,8 @@ public class RocketMQSender {
     @Value("${rocketmq.producer.send-message-timeout:3000}")
     private Long messageTimeOut;
 
-    public void sendMsg(String topic,String tag,String key) {
-        Message message = MessageBuilder.withPayload("").setHeader("KEYS", key).build();
-        rocketMQTemplate.syncSend(topic+":"+tag,message,messageTimeOut);
-    }
-
-    public void sendMsg(String topic,String tag,String key,Object body) {
-        Message message = MessageBuilder.withPayload(body).setHeader("KEYS", key).build();
-        rocketMQTemplate.syncSend(topic+":"+tag,message,messageTimeOut);
+    public void sendMsg(String topic,String tag,Object body) {
+        rocketMQTemplate.syncSend(topic+":"+tag,body,messageTimeOut);
     }
 
 /*    *//**