[rabbitmq-discuss] SharedQueue closed error

[anate]

Thank you for the reply. I am trying to insert the data into database and
would like to keep the message in RabbitMQ if the insert fails. I am not
sure if I am in right path. Could you please let me know more info about
"subclass DefaultConsumer and override HandleDelivery"? Please let me know
if there are any code examples.

> QueueingConsumer will accumulate deliveries locally in a shared queue.
> My guess is that QueueingConsumer shuts the shared internal queue down
> when a protocol exception occurs.

> Judging from your code you don’t need to use a QueueingConsumer. Simply
> subclass DefaultConsumer and override HandleDelivery. 



--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/SharedQueue-closed-error-tp34504p34528.html
Sent from the RabbitMQ mailing list archive at Nabble.com.