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