fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
laodaming 2023-07-28 17:43:19 +08:00
parent 297c65776b
commit b8c77f1db1
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
initalize/rabbitmq.go
View File

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