测试代码

src/main/java/com/usky/dxtop/service/listener/ChargeMqListener.java

@@ -4,11 +4,9 @@ import com.alibaba.fastjson.JSONObject;
 import com.usky.dxtop.common.exception.CustomException;
 import com.usky.dxtop.model.Order;
 import com.usky.dxtop.service.OrderService;
-import com.usky.dxtop.service.config.rabbitmq.charge.ChargeProduceConfig;
 import com.usky.dxtop.service.emun.OrderStatus;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -24,7 +22,7 @@ public class ChargeMqListener {
 
     @Autowired
     private OrderService orderService;
-    @RabbitListener(queues = ChargeProduceConfig.NAME, containerFactory = ChargeProduceConfig.LISTENER)
+//    @RabbitListener(queues = ChargeProduceConfig.NAME, containerFactory = ChargeProduceConfig.LISTENER)
     public void dealDeclareMessage(Message message) {
         try {
             //消息类型

src/main/java/com/usky/dxtop/service/listener/ChargeTransMqListener.java

@@ -3,10 +3,8 @@ package com.usky.dxtop.service.listener;
 import com.alibaba.fastjson.JSONObject;
 import com.usky.dxtop.model.Charge;
 import com.usky.dxtop.service.ChargeService;
-import com.usky.dxtop.service.config.rabbitmq.ChargeTransConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -23,7 +21,7 @@ public class ChargeTransMqListener {
     @Autowired
     private ChargeService chargeService;
 
-    @RabbitListener(queues = ChargeTransConfig.NAME, containerFactory = ChargeTransConfig.LISTENER)
+//    @RabbitListener(queues = ChargeTransConfig.NAME, containerFactory = ChargeTransConfig.LISTENER)
     public void dealDeclareMessage(Message message) {
         try {
             //消息类型

src/main/java/com/usky/dxtop/service/listener/DishTransMqListener.java

@@ -3,10 +3,8 @@ package com.usky.dxtop.service.listener;
 import com.alibaba.fastjson.JSONObject;
 import com.usky.dxtop.model.Dish;
 import com.usky.dxtop.service.DishService;
-import com.usky.dxtop.service.config.rabbitmq.DishTransConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -26,7 +24,7 @@ public class DishTransMqListener {
     private DishService dishService;
 
 
-    @RabbitListener(queues = DishTransConfig.NAME, containerFactory = DishTransConfig.LISTENER)
+//    @RabbitListener(queues = DishTransConfig.NAME, containerFactory = DishTransConfig.LISTENER)
     public void dealDeclareMessage(Message message) {
         try {
             //消息类型