search

tx7do / kratos-transport

kratos transport layer extension
MIT License
348 stars 95 forks source link

`subscriber.ch` isn't closed in the event of unexpected disconnection #20

Closed ryan961 closed 2 years ago

ryan961 commented 2 years ago

https://github.com/tx7do/kratos-transport/blob/2f9eed15b743d881f2efd23834fb4a54c3b0ef71/broker/rabbitmq/connection.go#L170

https://github.com/tx7do/kratos-transport/blob/2f9eed15b743d881f2efd23834fb4a54c3b0ef71/broker/rabbitmq/subscriber.go#L101

Related issue：https://github.com/rabbitmq/amqp091-go/issues/18