唯品会链接解析升级

admin

2024-04-26 5e7b0ed4a154ad067cbcf4aa1a1c7cce32f9864c

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/MQMsgBodyFactory.java

@@ -1,18 +1,18 @@
package com.yeshi.fanli.util.rocketmq;



import com.aliyun.openservices.ons.api.Message;

import com.google.gson.Gson;

import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;



public class MQMsgBodyFactory {

	
   public static Message create(MQTopicName topic,OrderTopicTagEnum tag,Object body){

      return new Message(topic.name(), tag.name(), new Gson().toJson(body).getBytes());

   }

	
   public static Message create(MQTopicName topic,UserTopicTagEnum tag,Object body){

      return new Message(topic.name(), tag.name(), new Gson().toJson(body).getBytes());

   }



}

package com.yeshi.fanli.util.rocketmq;

import com.aliyun.openservices.ons.api.Message;
import com.google.gson.Gson;
import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;
import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

public class MQMsgBodyFactory {
	
   public static Message create(MQTopicName topic,OrderTopicTagEnum tag,Object body){
      return new Message(topic.name(), tag.name(), new Gson().toJson(body).getBytes());
   }
	
   public static Message create(MQTopicName topic,UserTopicTagEnum tag,Object body){
      return new Message(topic.name(), tag.name(), new Gson().toJson(body).getBytes());
   }

}