Return-Path: Delivered-To: apmail-camel-users-archive@www.apache.org Received: (qmail 45735 invoked from network); 2 Jun 2010 17:50:18 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 2 Jun 2010 17:50:18 -0000 Received: (qmail 81591 invoked by uid 500); 2 Jun 2010 17:50:18 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 81567 invoked by uid 500); 2 Jun 2010 17:50:18 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Received: (qmail 81559 invoked by uid 99); 2 Jun 2010 17:50:18 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 02 Jun 2010 17:50:18 +0000 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests=FREEMAIL_FROM,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of claus.ibsen@gmail.com designates 74.125.82.45 as permitted sender) Received: from [74.125.82.45] (HELO mail-ww0-f45.google.com) (74.125.82.45) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 02 Jun 2010 17:50:12 +0000 Received: by wwb13 with SMTP id 13so1662989wwb.32 for ; Wed, 02 Jun 2010 10:49:52 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:mime-version:received:in-reply-to :references:from:date:message-id:subject:to:content-type :content-transfer-encoding; bh=k33+R4QiFBt2C8CuWCSOiF5s8jOgdHRaeY9dY6kgffI=; b=TJCXHpp/OYtcJUi5mvcPJ9Xn+heo6qP+gAxo13zhvK0Uefm1r+Pc20RXl3S45+omQW LYIk/GS3T1VI7mCh6ReGd05TizXaxBfbXC4pQ3FvcsRqrDIO5i0sbm0j3lu+dg7hgHMW ZDaxpTg0zPQHfg8wGQxp6q1PAffuEFgzT0OqU= 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=VcTKzMvPC9Z9TXjOTxq3257L8lihZIdZ3HQnC9Uifg7zhgLOaOHSyWf06nWlWkBItb CkQ7qEMlX9vphKSBHph+rOiukj89q4WJ11RWfqcbJtykQ+jhfWf/8W6m3lYOHLWnw4Aa eSPDfbHPp4lP1sYinaILh65FS70JPDAdAjsTM= Received: by 10.216.155.141 with SMTP id j13mr322968wek.7.1275500533578; Wed, 02 Jun 2010 10:42:13 -0700 (PDT) MIME-Version: 1.0 Received: by 10.216.6.140 with HTTP; Wed, 2 Jun 2010 10:41:53 -0700 (PDT) In-Reply-To: <28756173.post@talk.nabble.com> References: <28756173.post@talk.nabble.com> From: Claus Ibsen Date: Wed, 2 Jun 2010 19:41:53 +0200 Message-ID: Subject: Re: Getting exception when using retryUntil with concurrentConsumers To: users@camel.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable X-Virus-Checked: Checked by ClamAV on apache.org The JMS endpoint ALREADY have set concurrent consumers. So avoid using threads in the route also. On Wed, Jun 2, 2010 at 5:32 PM, Srini97 wrote: > > Hello All, > > I am using the concurrentConsumers option and try to retry the delivery w= hen > it fails. =A0with out concurrentConsumers retryUntil is it is working wel= l but > when I tried to use concurrent consumers it is failing .Below is the code > that i am using for the concurrentCosumers following the exception I am > getting. > > > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0from("jms-= cif:queue:" + > _notificationQueue+"?concurrentConsumers=3D"+concurrentConsumersSize). > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0threads(co= ncurrentConsumersSize). > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0process(pr= ocessor) > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 = =A0 =A0 =A0 =A0 =A0 =A0.onException(Exception.class).retryUntil(bean("myRet= ryBean")).end() > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 = =A0 =A0 =A0 =A0 =A0 =A0.recipientList(header("recipientListHeader").tokeniz= e(",")) > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 = =A0 =A0 =A0 =A0 =A0 =A0.parallelProcessing().executorService(customThreadPo= olExecutor) > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 = =A0 =A0 =A0 =A0 =A0 =A0.aggregationStrategy(new > RecipientAggregationStrategy(deliveryEndpoints, _endpointDeliveredBaseUri= )) > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 = =A0 =A0 =A0 =A0 =A0 =A0.to("direct:chunk.completed"); > > > > > > and the exception I am getting is below > > > 2010-06-02 15:28:54,770 [Camel Thread 0 - Threads] INFO > com.opta.delivery.webservices.WebServicesWrapper =A0- endpointtaken respo= nse > content: > 2010-06-02 15:28:54,770 [Camel Thread 0 - Threads] DEBUG > com.opta.delivery.FeedNotificationProcessor =A0- recipientList: > ftp://criv111e@somehost?fileName=3Dcif-protype%2Ff09%2Ffesdfsdfsed.xml&pa= ssword=3DDELLsdfsdf3&tempFileName=3D%24%7Bfile%3Aname.noext%7D.tmp > 2010-06-02 15:28:55,567 [pool-1-thread-1] WARN > org.apache.camel.component.file.remote.RemoteFileProducer =A0- Writing fi= le > failed with: File operation failed: 530 Not logged in. > . Code: 530 > 2010-06-02 15:28:55,629 [pool-1-thread-1] ERROR > org.apache.camel.processor.DefaultErrorHandler =A0- Failed delivery for > exchangeId: b3047673-dbb2-4f57-a10a-513002fd86f7. Exhausted after deliver= y > attempt: 1 caught: > org.apache.camel.component.file.GenericFileOperationFailedException: File > operation failed: 530 Not logged in. > . Code: 530 > org.apache.camel.component.file.GenericFileOperationFailedException: File > operation failed: 530 Not logged in. > . Code: 530 > =A0 =A0 =A0 =A0at > org.apache.camel.component.file.remote.FtpOperations.connect(FtpOperation= s.java:147) > =A0 =A0 =A0 =A0at > org.apache.camel.component.file.remote.RemoteFileProducer.connectIfNecess= ary(RemoteFileProducer.java:170) > =A0 =A0 =A0 =A0at > org.apache.camel.component.file.remote.RemoteFileProducer.preWriteCheck(R= emoteFileProducer.java:123) > =A0 =A0 =A0 =A0at > org.apache.camel.component.file.GenericFileProducer.processExchange(Gener= icFileProducer.java:75) > =A0 =A0 =A0 =A0at > org.apache.camel.component.file.remote.RemoteFileProducer.process(RemoteF= ileProducer.java:49) > =A0 =A0 =A0 =A0at > org.apache.camel.processor.RedeliveryErrorHandler.processExchange(Redeliv= eryErrorHandler.java:185) > =A0 =A0 =A0 =A0at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(Red= eliveryErrorHandler.java:151) > =A0 =A0 =A0 =A0at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryError= Handler.java:89) > =A0 =A0 =A0 =A0at > org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandle= r.java:49) > =A0 =A0 =A0 =A0at > org.apache.camel.processor.MulticastProcessor.doProcess(MulticastProcesso= r.java:278) > =A0 =A0 =A0 =A0at > org.apache.camel.processor.MulticastProcessor.access$000(MulticastProcess= or.java:62) > =A0 =A0 =A0 =A0at > org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.j= ava:199) > =A0 =A0 =A0 =A0at > org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.j= ava:193) > =A0 =A0 =A0 =A0at java.util.concurrent.FutureTask$Sync.innerRun(FutureTas= k.java:303) > =A0 =A0 =A0 =A0at java.util.concurrent.FutureTask.run(FutureTask.java:138= ) > =A0 =A0 =A0 =A0at > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor= .java:886) > =A0 =A0 =A0 =A0at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.jav= a:908) > =A0 =A0 =A0 =A0at java.lang.Thread.run(Thread.java:619) > > > can any body help on this. > > Cheers > Sri > > > -- > View this message in context: http://old.nabble.com/Getting-exception-whe= n-using-retryUntil-with-concurrentConsumers-tp28756173p28756173.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