suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:mq

Browse Source
This commit is contained in:
苏竹红
2025-09-25 17:50:08 +08:00
parent 6ff4a7811f
commit 6bc6a3262a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java
View File

@@ -89,7 +89,7 @@ public class ConsumerClient {
@Bean(initMethod = "start", destroyMethod = "shutdown") @Bean(initMethod = "start", destroyMethod = "shutdown")
public ConsumerBean test() { public ConsumerBean storeUserUpdate() {
RocketMqGroupEnum groupEnum = RocketMqGroupEnum.STORE_USER_UPDATE; RocketMqGroupEnum groupEnum = RocketMqGroupEnum.STORE_USER_UPDATE;
ConsumerBean consumerBean = new ConsumerBean(); ConsumerBean consumerBean = new ConsumerBean();
//配置文件 //配置文件