fix:Stream(),The return value will not cancel

streadway / amqp

Go client for AMQP 0.9.1

http://godoc.org/github.com/streadway/amqp

BSD 2-Clause "Simplified" License

4.88k stars 621 forks source link

fix:Stream(),The return value will not cancel #519

Open jeffmingup opened 2 years ago

jeffmingup commented 2 years ago

In the example, the return value of the Steam method amqp.delivery will not cancel. When I restart Rabbitmq, amqp.delivery will not be canceled. Because this place is blocked