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

camel-rabbit exclusive consumer


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

Looking at 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 ?


( ! ) 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
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
10.0006363032{main}( ).../msg03466.html:0