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



( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-camel-users/msg03466.html on line 97
Call Stack
#TimeMemoryFunctionLocation
10.0006363032{main}( ).../msg03466.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-camel-users/msg03466.html on line 97
Call Stack
#TimeMemoryFunctionLocation
10.0006363032{main}( ).../msg03466.html:0