From e75b0d79535a6bcd147cca4a54632b70b42afdb9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 29 五月 2021 18:10:18 +0800
Subject: [PATCH] 特价完善
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/MQMsgBodyFactory.java | 36 ++++++++++++++++++------------------
1 files changed, 18 insertions(+), 18 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/MQMsgBodyFactory.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/MQMsgBodyFactory.java
index e09893c..f997708 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/MQMsgBodyFactory.java
+++ b/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());
+ }
+
+}
--
Gitblit v1.8.0