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.
