Fixed Subscriber channel leak described in #59 - Githubissues

ScalaConsultants / reactive-rabbit

Reactive Streams driver for AMQP protocol. Powered by RabbitMQ library.

Apache License 2.0

184 stars 40 forks source link

Fixed Subscriber channel leak described in #59 #60

Closed breckcs closed 7 years ago

breckcs commented 7 years ago

Only open the RabbitMQ channel when the Subscriber is subscribed to.
Ensure open RabbitMQ channels are closed in the finalize method.
Resolves Issue #59.