diff --git a/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java b/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java index 34a6ba0e1..e720e5c03 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java @@ -89,7 +89,7 @@ public class ConsumerClient { @Bean(initMethod = "start", destroyMethod = "shutdown") - public ConsumerBean test() { + public ConsumerBean storeUserUpdate() { RocketMqGroupEnum groupEnum = RocketMqGroupEnum.STORE_USER_UPDATE; ConsumerBean consumerBean = new ConsumerBean(); //配置文件