git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

camel-rabbit exclusive consumer


Hi

I'm using camel-rabbit 2.21.1 and want to
create an exclusive consumer. I've tried using the exclusive=true
option but that creates an exclusive queue which may only be accessed
by the current connection and is deleted when that connection closes.
I want to be able to lock an existing durable queue for my exclusive
use.

Looking at org.apache.camel.component.rabbitmq.RabbitConsumer.java I
see it does:

tag = channel.basicConsume(consumer.getEndpoint().getQueue(),
consumer.getEndpoint().isAutoAck(), this);

To support an exclusive consumer I think it needs to call the
overloaded version of basicConsume:

basicConsume(java.lang.String queue,
                              boolean noAck,
                              java.lang.String consumerTag,
                              boolean noLocal,
                              boolean exclusive,
                              Consumer callback)

Is there an option I have overlooked ?

Thanks