diff --git a/consume/zhios_tikTok_goods_update.go b/consume/zhios_tikTok_goods_update.go index d2b1223..7c3e4dc 100644 --- a/consume/zhios_tikTok_goods_update.go +++ b/consume/zhios_tikTok_goods_update.go @@ -26,7 +26,7 @@ func ZhiosTikTokUpdate(queue md.MqQueue) { ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) //2、取出数据进行消费 ch.Qos(15) - delivery := ch.Consume(queue.Name, true) + delivery := ch.Consume(queue.Name, false) var res amqp.Delivery var ok bool