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: Getting exception when using retryUntil with concurrentConsumers
Date Wed, 02 Jun 2010 17:41:53 GMT
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 <sri.tech97@googlemail.com> wrote:
>
> Hello All,
>
> I am using the concurrentConsumers option and try to retry the delivery when
> it fails.  with out concurrentConsumers retryUntil is it is working well 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.
>
>
>                                from("jms-cif:queue:" +
> _notificationQueue+"?concurrentConsumers="+concurrentConsumersSize).
>                                threads(concurrentConsumersSize).
>                                process(processor)
>                                                .onException(Exception.class).retryUntil(bean("myRetryBean")).end()
>                                                .recipientList(header("recipientListHeader").tokenize(","))
>                                                .parallelProcessing().executorService(customThreadPoolExecutor)
>                                                .aggregationStrategy(new
> RecipientAggregationStrategy(deliveryEndpoints, _endpointDeliveredBaseUri))
>                                                .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  - endpointtaken response
> content: <response proceed="true" />
> 2010-06-02 15:28:54,770 [Camel Thread 0 - Threads] DEBUG
> com.opta.delivery.FeedNotificationProcessor  - recipientList:
> ftp://criv111e@somehost?fileName=cif-protype%2Ff09%2Ffesdfsdfsed.xml&password=DELLsdfsdf3&tempFileName=%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  - Writing file
> 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  - Failed delivery for
> exchangeId: b3047673-dbb2-4f57-a10a-513002fd86f7. Exhausted after delivery
> 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
>        at
> org.apache.camel.component.file.remote.FtpOperations.connect(FtpOperations.java:147)
>        at
> org.apache.camel.component.file.remote.RemoteFileProducer.connectIfNecessary(RemoteFileProducer.java:170)
>        at
> org.apache.camel.component.file.remote.RemoteFileProducer.preWriteCheck(RemoteFileProducer.java:123)
>        at
> org.apache.camel.component.file.GenericFileProducer.processExchange(GenericFileProducer.java:75)
>        at
> org.apache.camel.component.file.remote.RemoteFileProducer.process(RemoteFileProducer.java:49)
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:185)
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:151)
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:89)
>        at
> org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
>        at
> org.apache.camel.processor.MulticastProcessor.doProcess(MulticastProcessor.java:278)
>        at
> org.apache.camel.processor.MulticastProcessor.access$000(MulticastProcessor.java:62)
>        at
> org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:199)
>        at
> org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:193)
>        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
>        at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>        at 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-when-using-retryUntil-with-concurrentConsumers-tp28756173p28756173.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