From 11b5d57e393464f0e62486ec49e5335ca0b780dc Mon Sep 17 00:00:00 2001
From: hongawen <83944980@qq.com>
Date: Fri, 11 Aug 2023 13:44:19 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=A8=E6=88=B7=E7=99=BB=E5=BD=95=E5=90=8E?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E5=A4=B4=E5=83=8F=E5=88=B0=E5=89=8D=E5=8F=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/njcn/mq/constant/{Topic.java => BusinessTopic.java}    | 2 +-
 .../main/java/com/njcn/mq/template/UserMessageTemplate.java    | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)
 rename pqs-common/common-mq/src/main/java/com/njcn/mq/constant/{Topic.java => BusinessTopic.java} (86%)

diff --git a/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/Topic.java b/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java
similarity index 86%
rename from pqs-common/common-mq/src/main/java/com/njcn/mq/constant/Topic.java
rename to pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java
index 9de9875fe..3947f134a 100644
--- a/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/Topic.java
+++ b/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java
@@ -5,7 +5,7 @@ package com.njcn.mq.constant;
  * @version 1.0.0
  * @date 2023年08月10日 15:30
  */
-public interface Topic {
+public interface BusinessTopic {
 
     /***
      * 测试阶段用的用户主题
diff --git a/pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java b/pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java
index 1d8e263b1..4cf1bd61b 100644
--- a/pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java
+++ b/pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java
@@ -1,6 +1,7 @@
 package com.njcn.mq.template;
 
 import com.njcn.middle.rocket.template.RocketMQEnhanceTemplate;
+import com.njcn.mq.constant.BusinessTopic;
 import com.njcn.mq.message.UserMessage;
 import org.apache.rocketmq.client.producer.SendResult;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
@@ -31,7 +32,7 @@ public class UserMessageTemplate extends RocketMQEnhanceTemplate {
         message.setKey(UUID.randomUUID().toString());
         message.setUserName(userName);
         message.setBirthday(birthday);
-        return send("member_enhance", "CREATE", message);
+        return send(BusinessTopic.NJCJ_USER_TOPIC, "CREATE", message);
     }
 
 }
\ No newline at end of file