diff --git a/consume/zhios_order_hjy.go b/consume/zhios_order_hjy.go index ae8c13f..00aaac6 100644 --- a/consume/zhios_order_hjy.go +++ b/consume/zhios_order_hjy.go @@ -117,7 +117,7 @@ func KsortToStr(params map[string]string) []string { return keys } func handleZhiosOrderHjy(msg []byte) error { - time.Sleep(time.Microsecond * 20) // 等待500毫秒 + //1、解析canal采集至mq中queue的数据结构体 var canalMsg *md.ZhiosOrderBuckle fmt.Println(string(msg))