you mean
from("jms-cif:queue:" +
_notificationQueue+"?concurrentConsumers="+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");
rather
from("jms-cif:queue:" +
_notificationQueue+"?concurrentConsumers="+concurrentConsumersSize).
threads(concurrentConsumersSize).
Regards
Sri
Claus Ibsen-2 wrote:
>
> 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
>
>
--
View this message in context:
http://old.nabble.com/Getting-exception-when-using-retryUntil-with-concurrentConsumers-tp28756173p28757854.html
Sent from the Camel - Users mailing list archive at Nabble.com.
