Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

用户登录后处理头像到前台

Browse Source
This commit is contained in:
hongawen
2023-08-11 13:44:19 +08:00
parent a6b693ce47
commit 11b5d57e39
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pqs-common/common-mq/src/main/java/com/njcn/mq/constant/Topic.java → pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java
View File

@@ -5,7 +5,7 @@ package com.njcn.mq.constant;
* @version 1.0.0 * @version 1.0.0
* @date 2023年08月10日 15:30 * @date 2023年08月10日 15:30
*/ */
public interface Topic { public interface BusinessTopic {
/*** /***
* 测试阶段用的用户主题 * 测试阶段用的用户主题

3
pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java
View File

@@ -1,6 +1,7 @@
package com.njcn.mq.template; package com.njcn.mq.template;
import com.njcn.middle.rocket.template.RocketMQEnhanceTemplate; import com.njcn.middle.rocket.template.RocketMQEnhanceTemplate;
import com.njcn.mq.constant.BusinessTopic;
import com.njcn.mq.message.UserMessage; import com.njcn.mq.message.UserMessage;
import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.apache.rocketmq.spring.core.RocketMQTemplate;
@@ -31,7 +32,7 @@ public class UserMessageTemplate extends RocketMQEnhanceTemplate {
message.setKey(UUID.randomUUID().toString()); message.setKey(UUID.randomUUID().toString());
message.setUserName(userName); message.setUserName(userName);
message.setBirthday(birthday); message.setBirthday(birthday);
return send("member_enhance", "CREATE", message); return send(BusinessTopic.NJCJ_USER_TOPIC, "CREATE", message);
} }
} }