更新

consume/zhios_acquisition_condition.go

@@ -35,7 +35,7 @@ func ZhiosAcquisitionCondition(queue md.MqQueue) {
 		res, ok = <-delivery
 		if ok == true {
 			//fmt.Println(string(res.Body))
-			fmt.Println(">>>>>>>>>>>>>>>>CanalOrderConsume<<<<<<<<<<<<<<<<<<<<<<<<<")
+			fmt.Println(">>>>>>>>>>>>>>>>ZhiosAcquisitionCondition<<<<<<<<<<<<<<<<<<<<<<<<<")
 			err = handleZhiosAcquisition(res.Body)
 			//_ = res.Reject(false)
 			fmt.Println(err)