From 9719bb2d64ba22813e89f80ab2d8ced6b20b055c Mon Sep 17 00:00:00 2001 From: ScmTble Date: Sun, 11 Sep 2022 16:02:40 +0800 Subject: [PATCH] fix RabbitListener stop bug --- rabbitmq/listener.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rabbitmq/listener.go b/rabbitmq/listener.go index c6011b2..698db3d 100644 --- a/rabbitmq/listener.go +++ b/rabbitmq/listener.go @@ -70,6 +70,6 @@ func (q RabbitListener) Start() { func (q RabbitListener) Stop() { q.channel.Close() - q.channel.Close() + q.conn.Close() close(q.forever) }