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