From b85e255c5fd539063d6bfff602c26d09d8472753 Mon Sep 17 00:00:00 2001 From: dengbiao Date: Wed, 25 Dec 2024 19:44:20 +0800 Subject: [PATCH] 1 --- consume/add_public_platoon_user_relation_commission.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/consume/add_public_platoon_user_relation_commission.go b/consume/add_public_platoon_user_relation_commission.go index 1f6c009..4d946d5 100644 --- a/consume/add_public_platoon_user_relation_commission.go +++ b/consume/add_public_platoon_user_relation_commission.go @@ -45,9 +45,9 @@ func AddPublicPlatoonUserRelationCommissionConsume(queue md.MqQueue) { utils.FilePutContents("AddPublicPlatoonUserRelationCommissionConsume_ERR", "[err]:"+err.Error()) _ = res.Reject(false) //TODO::重新推回队列末尾，避免造成队列堵塞 - var msg *md2.AddPublicPlatoonUserRelationCommissionReq - json.Unmarshal(res.Body, &msg) - ch.Publish(queue.ExchangeName, msg, queue.RoutKey) + //var msg *md2.AddPublicPlatoonUserRelationCommissionReq + //json.Unmarshal(res.Body, &msg) + //ch.Publish(queue.ExchangeName, msg, queue.RoutKey) } else { _ = res.Ack(true) }