2.0.6

yujian

2019-12-25 a3ead770c30b310b9b1b7e3786d5d847da540e55

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()); 
    } 
 
}