diff --git a/rabbit/pool.go b/rabbit/pool.go index ca95f59..218a421 100644 --- a/rabbit/pool.go +++ b/rabbit/pool.go @@ -401,14 +401,14 @@ func (ch *Channel) Publish(exchange string, body interface{}, key string) { } // 接收某个消息队列的消息 -func (ch *Channel) Consume(name string) <-chan amqp.Delivery { +func (ch *Channel) Consume(name string, autoAck bool) <-chan amqp.Delivery { c, e := ch.Channel.Consume( - name, // 指定从哪个队列中接收消息 - "", // 用来区分多个消费者 - false, // 是否自动应答 - false, // 是否独有 - false, // 如果设置为true,表示不能将同一个connection中发送的消息传递给这个connection中的消费者 - false, // 列是否阻塞 + name, // 指定从哪个队列中接收消息 + "", // 用来区分多个消费者 + autoAck, // 是否自动应答 + false, // 是否独有 + false, // 如果设置为true,表示不能将同一个connection中发送的消息传递给这个connection中的消费者 + false, // 列是否阻塞 nil, ) failOnError(e, "接收消息失败!") diff --git a/test/single_queue_test.go b/test/single_queue_test.go index 70c0420..5a453f3 100644 --- a/test/single_queue_test.go +++ b/test/single_queue_test.go @@ -98,7 +98,7 @@ func TestReceive1(t *testing.T) { defer ch.Release() ch.Qos(5) - delivery := ch.Consume(SingleQueueName) + delivery := ch.Consume(SingleQueueName, false) var res amqp.Delivery var ok bool