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 {