fix RabbitListener stop bug

zeromicro · Sep 11, 2022 · 9719bb2 · 9719bb2
1 parent c8212f9
commit 9719bb2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 }