From 15ecc89e9db7fb9d5a54b2d16787bf861d925658 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Wed, 3 Jan 2024 18:24:13 +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/canal_guide_order_by_user_up_lv_consume.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consume/canal_guide_order_by_user_up_lv_consume.go b/consume/canal_guide_order_by_user_up_lv_consume.go index c45bbf5..c78fa60 100644 --- a/consume/canal_guide_order_by_user_up_lv_consume.go +++ b/consume/canal_guide_order_by_user_up_lv_consume.go @@ -26,7 +26,7 @@ func CanalGuideOrderByUserUpLvConsume(queue md.MqQueue) { //1、将自己绑定到交换机上 ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) //2、取出数据进行消费 - ch.Qos(1000) + ch.Qos(100) delivery := ch.Consume(queue.Name, true) //设置自动应答 geoIp2db, _ := geoip2db.NewGeoipDbByStatik()