From bc61fe3e3335b7f9d7de18f86c2e45e4215d0b53 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Tue, 13 Jun 2023 14:03:29 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8A=96=E9=9F=B3=E5=9B=A2=E9=95=BF=E5=95=86?= =?UTF-8?q?=E5=93=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consume/zhios_tikTok_goods_update.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/consume/zhios_tikTok_goods_update.go b/consume/zhios_tikTok_goods_update.go index 132f219..d2b1223 100644 --- a/consume/zhios_tikTok_goods_update.go +++ b/consume/zhios_tikTok_goods_update.go @@ -25,8 +25,8 @@ func ZhiosTikTokUpdate(queue md.MqQueue) { //1、将自己绑定到交换机上 ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) //2、取出数据进行消费 - ch.Qos(10) - delivery := ch.Consume(queue.Name, false) + ch.Qos(15) + delivery := ch.Consume(queue.Name, true) var res amqp.Delivery var ok bool