发圈重复

admin

2020-05-30 17118d16cb856b92da39d438e7436a54bce4eaf0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
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()); 
    } 
 
}