QueueSubscription will fail and run Subscriber.onError if the queue is deleted during when the demand is equal to zero

ScalaConsultants / reactive-rabbit

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

Apache License 2.0

184 stars 40 forks source link

QueueSubscription will fail and run Subscriber.onError if the queue is deleted during when the demand is equal to zero #2

Closed mkiedys closed 9 years ago

mkiedys commented 9 years ago

Since there is no active subscription the RabbitMQ driver is unable to tell that queue has been deleted and QueueSubscription will try to register new com.rabbitmq.client.Consumer after receiving Subscription.request(n: Long).

Related to #1

mkiedys commented 9 years ago

Fixed: d9c2bf3