been加载的优先级问题

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

@@ -2,6 +2,7 @@ package com.usky.dxtop.service.listener;
 
 import com.usky.dxtop.common.exception.CustomException;
 import com.usky.dxtop.service.MsgLogService;
+import com.usky.dxtop.service.config.rabbitmq.RabbitmqFactoryAware;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
@@ -27,6 +28,8 @@ public class CartGetMqListener {
 
     @Autowired
     private MsgLogService msgLogService;
+    @Autowired
+    private RabbitmqFactoryAware rabbitmqFactoryAware;
 
     @Transactional(rollbackFor = Exception.class)
     @RabbitListener(queues = QUEUE_NAME, containerFactory = LISTENER_NAME)

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

@@ -5,11 +5,13 @@ import com.usky.dxtop.common.utils.StringUtils;
 import com.usky.dxtop.model.Order;
 import com.usky.dxtop.service.MsgLogService;
 import com.usky.dxtop.service.OrderService;
+import com.usky.dxtop.service.config.rabbitmq.RabbitmqFactoryAware;
 import com.usky.dxtop.service.constant.MsgLogBusinessCode;
 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.amqp.rabbit.listener.RabbitListenerContainerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
@@ -32,6 +34,8 @@ public class ChargeMqListener {
     private OrderService orderService;
     @Autowired
     private MsgLogService msgLogService;
+    @Autowired
+    private RabbitmqFactoryAware rabbitmqFactoryAware;
 
     @Transactional(rollbackFor = Exception.class)
     @RabbitListener(queues = QUEUE_NAME, containerFactory = LISTENER_NAME)

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

@@ -10,6 +10,7 @@ import com.usky.dxtop.service.ChargeService;
 import com.usky.dxtop.service.StaffService;
 import com.usky.dxtop.service.api.WxApi;
 import com.usky.dxtop.service.config.rabbitmq.ChargeTransConfig;
+import com.usky.dxtop.service.config.rabbitmq.RabbitmqFactoryAware;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
@@ -40,6 +41,8 @@ public class ChargeTransMqListener {
     @Autowired
     private WxApi wxApi;
 
+    @Autowired
+    private RabbitmqFactoryAware rabbitmqFactoryAware;
     @RabbitListener(queues = ChargeTransConfig.NAME, containerFactory = ChargeTransConfig.LISTENER)
     public void dealDeclareMessage(Message message) {
         try {

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

@@ -9,6 +9,7 @@ import com.usky.dxtop.model.Staff;
 import com.usky.dxtop.service.DishService;
 import com.usky.dxtop.service.StaffService;
 import com.usky.dxtop.service.api.WxApi;
+import com.usky.dxtop.service.config.rabbitmq.RabbitmqFactoryAware;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
@@ -38,6 +39,8 @@ public class DishTransMqListener {
     private StaffService staffService;
     @Autowired
     private WxApi wxApi;
+    @Autowired
+    private RabbitmqFactoryAware rabbitmqFactoryAware;
 
     @RabbitListener(queues = QUEUE_NAME, containerFactory = LISTENER_NAME)
     public void dealDeclareMessage(Message message) {

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

@@ -4,6 +4,7 @@ import com.usky.dxtop.common.utils.StringUtils;
 import com.usky.dxtop.model.Staff;
 import com.usky.dxtop.service.MsgLogService;
 import com.usky.dxtop.service.StaffService;
+import com.usky.dxtop.service.config.rabbitmq.RabbitmqFactoryAware;
 import com.usky.dxtop.service.constant.MsgLogBusinessCode;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -30,6 +31,8 @@ public class FaceMqListener {
     @Autowired
     private StaffService staffService;
 
+    @Autowired
+    private RabbitmqFactoryAware rabbitmqFactoryAware;
     @RabbitListener(queues = QUEUE_NAME, containerFactory = LISTENER_NAME)
     public void dealDeclareMessage(Message message) {
         try {

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

@@ -4,6 +4,7 @@ import com.usky.dxtop.common.utils.StringUtils;
 import com.usky.dxtop.model.Dept;
 import com.usky.dxtop.service.DeptService;
 import com.usky.dxtop.service.MsgLogService;
+import com.usky.dxtop.service.config.rabbitmq.RabbitmqFactoryAware;
 import com.usky.dxtop.service.constant.MsgLogBusinessCode;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -28,7 +29,8 @@ public class GroupMqListener {
     private MsgLogService msgLogService;
     @Autowired
     private DeptService deptService;
-
+    @Autowired
+    private RabbitmqFactoryAware rabbitmqFactoryAware;
     @RabbitListener(queues = QUEUE_NAME, containerFactory = LISTENER_NAME)
     public void dealDeclareMessage(Message message) {
         try {

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

@@ -4,6 +4,7 @@ import com.usky.dxtop.common.utils.StringUtils;
 import com.usky.dxtop.model.Staff;
 import com.usky.dxtop.service.MsgLogService;
 import com.usky.dxtop.service.StaffService;
+import com.usky.dxtop.service.config.rabbitmq.RabbitmqFactoryAware;
 import com.usky.dxtop.service.constant.MsgLogBusinessCode;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -28,6 +29,8 @@ public class PersonMqListener {
     private MsgLogService msgLogService;
     @Autowired
     private StaffService staffService;
+    @Autowired
+    private RabbitmqFactoryAware rabbitmqFactoryAware;
     @RabbitListener(queues = QUEUE_NAME, containerFactory = LISTENER_NAME)
     public void dealDeclareMessage(Message message) {
         try {