DengBiao
1 year ago
1 changed files with 4 additions and 4 deletions
Unified View
Diff Options
+ 4
- 4
consume/zhios_tikTok_goods_update.go
View File
| @@ -25,8 +25,8 @@ func ZhiosTikTokUpdate(queue md.MqQueue) { | |||||
| //1、将自己绑定到交换机上 | //1、将自己绑定到交换机上 | ||||
| ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) | ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) | ||||
| //2、取出数据进行消费 | //2、取出数据进行消费 | ||||
| ch.Qos(15) | |||||
| delivery := ch.Consume(queue.Name, false) | |||||
| ch.Qos(20) | |||||
| delivery := ch.Consume(queue.Name, true) | |||||
| var res amqp.Delivery | var res amqp.Delivery | ||||
| var ok bool | var ok bool | ||||
| @@ -38,7 +38,7 @@ func ZhiosTikTokUpdate(queue md.MqQueue) { | |||||
| err = handleZhiosTikTokGoodsUpdate(res.Body) | err = handleZhiosTikTokGoodsUpdate(res.Body) | ||||
| //_ = res.Reject(false) | //_ = res.Reject(false) | ||||
| //if err == nil { | //if err == nil { | ||||
| _ = res.Ack(true) | |||||
| //_ = res.Ack(true) | |||||
| //} | //} | ||||
| } else { | } else { | ||||
| panic(errors.New("error getting message")) | panic(errors.New("error getting message")) | ||||
| @@ -70,7 +70,7 @@ func ZhiosTikTokAllUpdate(queue md.MqQueue) { | |||||
| err = handleZhiosTikTokGoodsUpdate(res.Body) | err = handleZhiosTikTokGoodsUpdate(res.Body) | ||||
| //_ = res.Reject(false) | //_ = res.Reject(false) | ||||
| //if err == nil { | //if err == nil { | ||||
| _ = res.Ack(true) | |||||
| //_ = res.Ack(true) | |||||
| //} | //} | ||||
| } else { | } else { | ||||
| panic(errors.New("error getting message")) | panic(errors.New("error getting message")) | ||||