xiufu

cmd/queue/sync_out_store/main.go

@@ -59,6 +59,7 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 	)
 	//先去转换队列消息的json,如果失败,记录起来
 	if err = json.Unmarshal(dataByte, &message); err != nil {
+		err = errors.New(string(dataByte))
 		goto ERR
 	}
 	//判断操作类型