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.tec...@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://criv1...@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
