Hi Sergey,
thanks for answer and sorry for late response, had to work on other tasks.
You are right, setting the option on amqp connection level works for
even-driven (default camel) routing, I just thought that it should be there
on camel component options level, i.e. after connection string in
Hi all,
I use camel to implement some routine for user-triggered data consumption.
When started/resumed it should poll data until there is no more and stop.
My route looks like:
from("timer:startPollingConsumer?delay=0&repeatCount=1").bean(myPollingConsumer);
The problem is that single event wit
Thanks for reply,
"current behaviour" means that it is not the "intended behaviour" and you
created a ticket to fix that, or that "current behaviour" IS actually the
"intended behaviour"? :)
--
View this message in context:
http://camel.465427.n5.nabble.com/Timer-with-delay-0-and-repeatCount-1
I try to use my custom PollingConsumerPollStrategy for AMQPComponent
endpoint, but my enpoint can't be created.
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint:
amqp:queue:broadcast.MY_QUEUE?pollStrategy=%23MyPollingConsumerPollStrategy
due to: There are 1 pa
Hi Claus,
thanks for answer. So how one should react on permanent errors happened
during consumption using polling consumer? In our case queue went wrong.
Claus Ibsen-2 wrote
> That option is not supported on amqp component.
>
> On Wed, Sep 25, 2013 at 3:02 PM, magner58 <
>
I create PollingConsumer for my AMQP queue and consume with receiveNoWait()
until null is received. It worked nicely in default mode, but in browsing
mode (queue name suffixed with "{mode: browse}", see
https://qpid.apache.org/books/0.12/Programming-In-Apache-Qpid/html/ch02s04.html
"2.4.3.3. browse
