Browse Source

更新

three
huangjiajun 1 year ago
parent
commit
fe69ea7e0d
2 changed files with 1 additions and 3 deletions
  1. +0
    -1
      consume/zhios_acquisition_condition.go
  2. +1
    -2
      consume/zhios_fast_return_order_pay.go

+ 0
- 1
consume/zhios_acquisition_condition.go View File

@@ -42,7 +42,6 @@ func ZhiosAcquisitionCondition(queue md.MqQueue) {
if err == nil { if err == nil {
_ = res.Ack(true) _ = res.Ack(true)
} else { } else {
_ = res.Reject(false)


var canalMsg *md.ZhiosAcquisition var canalMsg *md.ZhiosAcquisition
var tmpString string var tmpString string


+ 1
- 2
consume/zhios_fast_return_order_pay.go View File

@@ -28,7 +28,7 @@ func ZhiosFastReturnOrderPay(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(5)
ch.Qos(20)
delivery := ch.Consume(queue.Name, false) delivery := ch.Consume(queue.Name, false)


var res amqp.Delivery var res amqp.Delivery
@@ -44,7 +44,6 @@ func ZhiosFastReturnOrderPay(queue md.MqQueue) {
if err == nil { if err == nil {
_ = res.Ack(true) _ = res.Ack(true)
} else { } else {
_ = res.Reject(false)
var canalMsg *md.ZhiosFatReturnOrderPay var canalMsg *md.ZhiosFatReturnOrderPay
var tmpString string var tmpString string
err := json.Unmarshal(res.Body, &tmpString) err := json.Unmarshal(res.Body, &tmpString)


Loading…
Cancel
Save