diff --git a/consume/one_circles_sign_in_consume.go b/consume/one_circles_sign_in_consume.go index ec91721..4bc9f1c 100644 --- a/consume/one_circles_sign_in_consume.go +++ b/consume/one_circles_sign_in_consume.go @@ -39,11 +39,12 @@ func OneCirclesSignInGreenEnergyConsume(queue md.MqQueue) { if err != nil { fmt.Println("err ::: ", err) utils.FilePutContents("OneCirclesSignInGreenEnergyConsume_ERR", "[err]:"+err.Error()) - _ = res.Reject(false) - //TODO::重新推回队列末尾,避免造成队列堵塞 - var msg *md.OneCirclesStructForSignIn - json.Unmarshal(res.Body, &msg) - ch.Publish(queue.ExchangeName, msg, queue.RoutKey) + _ = res.Reject(true) + //_ = res.Reject(false) + ////TODO::重新推回队列末尾,避免造成队列堵塞 + //var msg *md.OneCirclesStructForSignIn + //json.Unmarshal(res.Body, &msg) + //ch.Publish(queue.ExchangeName, msg, queue.RoutKey) } else { _ = res.Ack(true) }