From 444d4907b4d54230e7d17cc904596bb891d86902 Mon Sep 17 00:00:00 2001
From: wucongxing8150 <815046773@qq.com>
Date: Wed, 29 May 2024 14:52:10 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BA=86amqp=E7=9A=84?=
 =?UTF-8?q?=E4=BD=BF=E7=94=A81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 extend/rabbitMq/rabbitMq.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/extend/rabbitMq/rabbitMq.go b/extend/rabbitMq/rabbitMq.go
index 0793c75..bc5a8a3 100644
--- a/extend/rabbitMq/rabbitMq.go
+++ b/extend/rabbitMq/rabbitMq.go
@@ -81,7 +81,7 @@ func (r *RabbitMQ) PublishWithDelay(exchangeName, routingKey string, message int
 		true,                                   // durable
 		false,                                  // auto-deleted
 		false,                                  // internal
-		false,                                  // no-wait
+		false,                                  // 阻塞处理
 		amqp.Table{"x-delayed-type": "direct"}, // arguments
 	)
 	if err != nil {
@@ -111,13 +111,13 @@ func (r *RabbitMQ) PublishWithDelay(exchangeName, routingKey string, message int
 }
 
 // Consume 消费
-func (r *RabbitMQ) Consume(queueName, exchangeName string) (<-chan amqp.Delivery, error) {
+func (r *RabbitMQ) Consume(queueName string) (<-chan amqp.Delivery, error) {
 	q, err := r.channel.QueueDeclare(
 		queueName, // 队列名称
-		false,     // 消息者名称
-		false,     // 是否确认消费
+		false,     // 是否持久化
+		false,     // 是否自动删除队列
 		false,     // 排他
-		false,     // no-wait
+		false,     // 阻塞处理
 		nil,       // arguments
 	)
 	if err != nil {