消费者自动创建

yzg-util-mq/src/main/java/com/yanzuoguang/mq/base/MqConsumeDynamic.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.mq.base;
 
 import com.yanzuoguang.mq.base.consumer.ConsumerSimpleMessageListenerContainer;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.ChannelAwareMessageListener;
 import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
 import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter;
@@ -21,12 +22,12 @@ public class MqConsumeDynamic {
     @Value("${yzg.onOfConsumer:10}")
     private int onOfConsumer;
 
-    public SimpleMessageListenerContainer init(String queueName, Object target, String methodName) {
+    public SimpleMessageListenerContainer init(String queueName, ChannelAwareMessageListener messageListener) {
         ConsumerSimpleMessageListenerContainer container = new ConsumerSimpleMessageListenerContainer();
         container.setConnectionFactory(connectionFactory);
         container.setQueueNames(queueName);
         container.setConcurrentConsumers(onOfConsumer);
-        container.setMessageListener(new MessageListenerAdapter(target, methodName));
+        container.setMessageListener(new MessageListenerAdapter(messageListener));
         container.start();
         return container;
     }