Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (nike.apache.org: domain of claus.ibsen@gmail.com
 designates 209.85.218.211 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:from:date:message-id:subject:to
         :content-type:content-transfer-encoding;
        b=p3nkA0j+arHCfSrNkXTDBBaMnIP51oz3+7M+NcqfMrL6IW1f5HhdYRFg6B4K8zqNoT
         rt+jg/XG1u6IMXQ7KGLQ2/5OMNPP08W7wm+zzfTgLKY9ZMNsA5RxzEKfslMa2EJedvOe
         4Rgh/HHUambO3ZrblssLaWw522ZKW96DHqwPY=
MIME-Version: 1.0
In-Reply-To: <26206508.post@talk.nabble.com>
References: <26202573.post@talk.nabble.com>
 <4AF1D4C4.7090207@die-schneider.net>
	<5380c69c0911041240s3e0cf124mb3e76036824394f5@mail.gmail.com>
	<26206508.post@talk.nabble.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Thu, 5 Nov 2009 07:23:37 +0100
Message-ID: <5380c69c0911042223v24f7e8e7lb9da6a1187d35835@mail.gmail.com>
Subject: Re: guaranteed message processing question...
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

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. =A0I added some parameters to the queue to make the route
> "transactional"...
>
> from("activemq:inboundMessages?maxConcurrentConsumers=3D50&lazyCreateTran=
sactionManager=3Dtrue&transacted=3Dtrue")
> .process(new Processor1())
> .process(new Processor2())
> .to("activemq:finishedQueue");
>
> Now I'm getting duplicates delivered. =A0My test pumped 10k messages into=
 the
> queue via an external client. =A0During the test, I restarted SMX 2 times=
.
> After the test concluded, I had 10,003 messages in the finishedQueue. =A0=
This
> is better than losing messages, but still not the desired behavior...any
> ideas?
>
> One more question, what happens during exception handling? =A0Suppose I h=
ave
> the following policy to retry 3 times, then go to an error queue...
>
> onException(Exception.class).handled(true).maximumRedeliveries(3).to("act=
ivemq:errorQueue");
>
> I assume the message is still in the inbound queue until either delivered=
 to
> the finished queue or error queue, correct? =A0So at any given time the s=
um 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-pr=
ocessing-question...-tp26202573p26206508.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>


--=20
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