|
@@ -26,7 +26,7 @@ func ZhiosTikTokUpdate(queue md.MqQueue) { |
|
|
ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) |
|
|
ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) |
|
|
//2、取出数据进行消费 |
|
|
//2、取出数据进行消费 |
|
|
ch.Qos(15) |
|
|
ch.Qos(15) |
|
|
delivery := ch.Consume(queue.Name, true) |
|
|
|
|
|
|
|
|
delivery := ch.Consume(queue.Name, false) |
|
|
|
|
|
|
|
|
var res amqp.Delivery |
|
|
var res amqp.Delivery |
|
|
var ok bool |
|
|
var ok bool |
|
|