From b8c77f1db1ab2e5628bae369cff00bc9e7cd3377 Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Fri, 28 Jul 2023 17:43:19 +0800 Subject: [PATCH] fix --- initalize/rabbitmq.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/initalize/rabbitmq.go b/initalize/rabbitmq.go index 5bfffa9e..3713a7b8 100644 --- a/initalize/rabbitmq.go +++ b/initalize/rabbitmq.go @@ -82,7 +82,7 @@ func (h *RabbitMqHandle) Consume(queueName constants.RABBIT_MQ, handleFunc func( } msgs, err := object.ch.Consume( object.queue.Name, // 队列名 - "", // 消费者名,如果为空,则是随机生成一个 + object.queue.Name, // 消费者名,如果为空,则是随机生成一个 false, // 自动应答 false, // 是否排他 false, // 是否阻塞