更新

consume/zhios_acquisition_condition.go

@@ -42,6 +42,8 @@ func ZhiosAcquisitionCondition(queue md.MqQueue) {
 			if err == nil {
 				_ = res.Ack(true)
 			} else {
+				_ = res.Reject(false)
+
 				var canalMsg *md.ZhiosAcquisition
 				var tmpString string
 				err := json.Unmarshal(res.Body, &tmpString)

consume/zhios_fast_return_order_pay.go

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