回收资源

2 years ago · f028a66a9d
parent 339940b810
commit f028a66a9d
1 changed files with 1 additions and 0 deletions
--- a/rabbitmq.go
+++ b/rabbitmq.go
@ -52,6 +52,7 @@ func (r *rabbitmq) Consume(queueName string, autoAck bool, callback func(amqp.De
 	if err != nil {
 		return err
 	}
 	defer ch.Close()
 	//消费队列
 	msgs, err := ch.Consume(
 		queueName, //队列名称