下载视频

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/MqService.java

@@ -83,6 +83,18 @@ public interface MqService {
     @ApiOperation(value = "动态注册消费者回调队列")
     SimpleMessageListenerContainer setQueueConsumer(String queueName, int concurrency, ChannelAwareMessageListener messageListener);
 
+    /**
+     * 动态注册消费者回调队列
+     *
+     * @param queueName       队列名称
+     * @param concurrency     　消费者数量
+     * @param maxConcurrency  　最大消费者数量
+     * @param messageListener 　消费者
+     * @return
+     */
+    @ApiOperation(value = "动态注册消费者回调队列")
+    SimpleMessageListenerContainer setQueueConsumer(String queueName, int concurrency, int maxConcurrency, ChannelAwareMessageListener messageListener);
+
 
     /**
      * 建立当前服务器的队列

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MessageSendServiceImpl.java

@@ -176,7 +176,7 @@ public class MessageSendServiceImpl implements MessageSendService {
      */
     @Override
     public SimpleMessageListenerContainer init(String queueName, int concurrency, ChannelAwareMessageListener messageListener) {
-        return this.init(queueName, concurrency, concurrency, messageListener);
+        return this.init(queueName, concurrency, 0, messageListener);
     }
 
     /**

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java

@@ -126,6 +126,20 @@ public class MqServiceImpl implements MqService {
         return this.messageSendService.init(queueName, concurrency, messageListener);
     }
 
+    /**
+     * 动态注册消费者回调队列
+     *
+     * @param queueName       队列名称
+     * @param concurrency     　消费者数量
+     * @param maxConcurrency  　最大消费者数量
+     * @param messageListener 　消费者
+     * @return
+     */
+    @Override
+    public SimpleMessageListenerContainer setQueueConsumer(String queueName, int concurrency, int maxConcurrency, ChannelAwareMessageListener messageListener) {
+        return this.messageSendService.init(queueName, concurrency, maxConcurrency, messageListener);
+    }
+
     /**
      * 建立当前服务器的队列
      *