发圈

yj

2020-03-06 ca53b2a58a60695d56dd2d523aa3658b8482b6de

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