From b74a6e247deb90dd79832a8ed19596ca11a40a81 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Sat, 27 Apr 2024 15:46:59 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consume/zhios_task_total.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consume/zhios_task_total.go b/consume/zhios_task_total.go index 9ed65ff..ac714e8 100644 --- a/consume/zhios_task_total.go +++ b/consume/zhios_task_total.go @@ -24,7 +24,7 @@ func ZhiosTaskTotal(queue md.MqQueue) { //1、将自己绑定到交换机上 ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) //2、取出数据进行消费 - ch.Qos(1) + ch.Qos(1000) delivery := ch.Consume(queue.Name, false) var res amqp.Delivery