修改地址

yzg-util-redis/src/main/java/com.yanzuoguang.redis/mq/PlanProcedure.java

@@ -39,7 +39,7 @@ public class PlanProcedure {
             // 创建队列,注册回调
             mqService.createQueue(new QueueVo(k));
             // 应用程序级的任务交给队列处理
-            mqService.setQueueConsumer(k, messageListener);
+            mqService.setQueueConsumer(k, 1, 1, messageListener);
         });
     }