diff --git a/api/amqp/consumer/CancelUnPayOrder.go b/api/amqp/consumer/CancelUnPayOrder.go
index ee7e2dc..3284f1e 100644
--- a/api/amqp/consumer/CancelUnPayOrder.go
+++ b/api/amqp/consumer/CancelUnPayOrder.go
@@ -76,7 +76,7 @@ func CancelUnPayOrder(msg amqp091.Delivery) {
 		if err != nil {
 			tx.Rollback()
 			utils.LogJsonErr("consumer.CancelUnPayOrder:", "订单异常")
-			_ = msg.Reject(true)
+			_ = msg.Ack(false)
 			return
 		}
 
@@ -101,7 +101,7 @@ func CancelUnPayOrder(msg amqp091.Delivery) {
 		if err != nil {
 			tx.Rollback()
 			utils.LogJsonErr("consumer.CancelUnPayOrder:", "订单异常")
-			_ = msg.Reject(true)
+			_ = msg.Ack(false)
 			return
 		}