Merge pull request #34 from ScmTble/master

fix RabbitListener stop bug
zeromicro · Oct 20, 2022 · 3e19b1f · 3e19b1f
2 parents 6129bd5 + 9719bb2
commit 3e19b1f
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)
 }