camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: guaranteed message processing question...
Date Thu, 05 Nov 2009 06:23:37 GMT
Hi

Do you use persistent queues? Then make sure the queues are empty when
testing. Maybe deleting the AMQ data folder before testing.


On Thu, Nov 5, 2009 at 12:23 AM, boday <boday@vektrel.com> wrote:
>
> thanks guys.  I added some parameters to the queue to make the route
> "transactional"...
>
> from("activemq:inboundMessages?maxConcurrentConsumers=50&lazyCreateTransactionManager=true&transacted=true")
> .process(new Processor1())
> .process(new Processor2())
> .to("activemq:finishedQueue");
>
> Now I'm getting duplicates delivered.  My test pumped 10k messages into the
> queue via an external client.  During the test, I restarted SMX 2 times.
> After the test concluded, I had 10,003 messages in the finishedQueue.  This
> is better than losing messages, but still not the desired behavior...any
> ideas?
>
> One more question, what happens during exception handling?  Suppose I have
> the following policy to retry 3 times, then go to an error queue...
>
> onException(Exception.class).handled(true).maximumRedeliveries(3).to("activemq:errorQueue");
>
> I assume the message is still in the inbound queue until either delivered to
> the finished queue or error queue, correct?  So at any given time the sum of
> the inbound, finished and error queues should equal to the number of
> messages sent, correct?
>
> I'm working on a unit test for this now, but wanted to make sure I
> understood the intended behavior first...
>
> thanks in advance
>
>
> -----
> Ben - Senior Consultant
>
> --
> View this message in context: http://old.nabble.com/guaranteed-message-processing-question...-tp26202573p26206508.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>



-- 
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus

Mime
View raw message