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,             // 是否阻塞