[rabbitmq-discuss] Why does Channel.queueDeclarePassive close the channel?

Yuesong Wang yuesong.c at gmail.com
Fri Feb 18 16:31:47 GMT 2011


I'm experimenting with RabbitMQ (2.3.1) and the Java client. I tried to use Channel.queueDeclarePassive to detect the presence/absence of a queue, but if the queue does not exit, the method shuts down the channel. Any reason why it does that?

What I really want to do is for both the producers and consumers to automatically recover from a queue gone missing, e.g. the owner node in a cluster goes down (I'm simulating that by deleting the queue while both producers and consumers are running). The producer will recreate the queue (with queueDeclare) and the consumers will use queueDeclarePassive to find the queue. Is there an established pattern for doing that efficiently?



More information about the rabbitmq-discuss mailing list