diff --git a/consume/zhios_order_total_second.go b/consume/zhios_order_total_second.go index 455ba5b..4b86efd 100644 --- a/consume/zhios_order_total_second.go +++ b/consume/zhios_order_total_second.go @@ -38,6 +38,7 @@ func ZhiosOrderTotalSecond(queue md.MqQueue) { err = handleZhiosOrderTotalSecond(res.Body) //_ = res.Reject(false) if err != nil { + fmt.Println("===================统计", err.Error()) _ = res.Reject(false) //TODO::重新推回队列末尾,避免造成队列堵塞 var msg *md.ZhiosOrderBuckle @@ -73,7 +74,6 @@ func handleZhiosOrderTotalSecond(msg []byte) error { fmt.Println("===with", err.Error()) return err } - fmt.Println(tmpString) err = json.Unmarshal([]byte(tmpString), &canalMsg) if err != nil { fmt.Println("===with", err.Error())