充值成功消息订阅

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/FanoutExchangeConfig.java

 package com.mmc.iuav.user.mq;
 
+import com.mmc.iuav.user.mq.constant.RabbitmqConstant;
 import org.springframework.amqp.core.Binding;
 import org.springframework.amqp.core.BindingBuilder;
 import org.springframework.amqp.core.FanoutExchange;
@@ -14,7 +15,7 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 public class FanoutExchangeConfig {
     @Bean
-    public FanoutExchange fanoutExchange(){
+    public FanoutExchange fanoutExchange() {
         return new FanoutExchange(RabbitmqConstant.USER_INFO_UPDATE_FANOUT_EXCHANGE);
     }
 

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/RabbitmqConstant.java

-package com.mmc.iuav.user.mq;
-
-/**
- * @author: zj
- * @Date: 2023/6/26 17:57
- */
-public class RabbitmqConstant {
-    public final static String USER_INFO_UPDATE_FANOUT_EXCHANGE = "USER_INFO_UPDATE_FANOUT_EXCHANGE";
-
-    public final static String USER_INFO_UPDATE_FANOUT_FORUM_QUEUE = "USER_INFO_UPDATE_FANOUT_FORUM_QUEUE";
-}

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/constant/RabbitmqConstant.java

 package com.mmc.iuav.user.mq.constant;
 
 /**
- * @author: lw
- * @Date: 2023/8/23 11:26
+ * @author: zj
+ * @Date: 2023/6/26 17:57
  */
 public class RabbitmqConstant {
+    public final static String USER_INFO_UPDATE_FANOUT_EXCHANGE = "USER_INFO_UPDATE_FANOUT_EXCHANGE";
+
+    public final static String USER_INFO_UPDATE_FANOUT_FORUM_QUEUE = "USER_INFO_UPDATE_FANOUT_FORUM_QUEUE";
+
     /**
      * 用户充值订单交换机
      */
@@ -20,5 +24,4 @@ public class RabbitmqConstant {
      */
     public final static String USER_TOP_UP_SUCCESS_QUEUE = "USER_TOP_UP_SUCCESS_QUEUE";
     public final static String USER_TOP_UP_SUCCESS_ROUTING_KEY = "USER_TOP_UP_SUCCESS_ROUTING_KEY";
-
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/impl/MqProducerImpl.java

@@ -3,7 +3,7 @@ package com.mmc.iuav.user.mq.impl;
 import com.alibaba.fastjson2.JSONObject;
 import com.mmc.iuav.user.model.vo.UserAccountVO;
 import com.mmc.iuav.user.mq.MqProducer;
-import com.mmc.iuav.user.mq.RabbitmqConstant;
+import com.mmc.iuav.user.mq.constant.RabbitmqConstant;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/listener/MqConsumer.java → csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/listener/OrderMqConsumer.java

@@ -19,7 +19,7 @@ import javax.annotation.Resource;
  */
 @Slf4j
 @Component
-public class MqConsumer {
+public class OrderMqConsumer {
     @Resource
     PayWalletService payWalletService;