1

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)
 			}