RE: Data Corruption in SFTP in Parallel Multicast branches

2015-11-04 Thread Siano, Stephan
related changes). Best regards Stephan -Original Message- From: deepaktaker [mailto:deepakta...@gmail.com] Sent: Donnerstag, 5. November 2015 04:12 To: users@camel.apache.org Subject: Re: Data Corruption in SFTP in Parallel Multicast branches Hi, I would like to know if the jira CAMEL

Re: Data Corruption in SFTP in Parallel Multicast branches

2015-11-04 Thread deepaktaker
Hi, I would like to know if the jira CAMEL-8284 created for the bug "Data Corruption in SFTP in Parallel Multicast branches" released as patch. i was wondering if the patch is made available in camel version 2.14 Regards, Deepak -- View this message in context: http://camel.465427.n5.nabb

Re: Data Corruption in SFTP in Parallel Multicast branches

2015-05-12 Thread Franz Paul Forsthofer
Hello Lakshmi, it could be that this issue is related to https://issues.apache.org/jira/browse/CAMEL-8688 There we have made a patch in the current snapshot (version 2.16) Can you try to reproduce your problem on the current snapshot? Regards Franz On Tue, May 12, 2015 at 11:39 AM, lakshmi.pra

Re: Data Corruption in SFTP in Parallel Multicast branches

2015-05-12 Thread lakshmi.prashant
Hi, If direct is changed to SEDA, the multiple branches still fail. /Error processing exchange. Exchange[Message: [Body is instance of org.apache.camel.StreamCache]]. Caused by: [org.quartz.JobExecutionException - org.apache.camel.CamelExchangeException: Parallel processing failed for number 0.

Re: Data Corruption in SFTP in Parallel Multicast branches

2015-04-21 Thread contactreji
Hi Have u tried replacing With Reji - Reji Mathews Sr. Developer - Middleware Integration / SOA ( Open Source - Apache Camel & Jboss Fuse ESB | Mule ESB ) LinkedIn - http://in.linkedin.com/pub/reji-mathews/31/9a2/40a Twitter - reji_mathews -- Vie

Re: Data Corruption in SFTP in Parallel Multicast branches

2015-04-20 Thread alexey-s
Try replacing the Multicast on the Recipient List with parallelProcessing=true. Multicast: The Multicast allows to route the same message to a number of endpoints and process them in a different way. Recipient List: The recipients will receive a copy of the same Exchange. -- View this message

Re: Data Corruption in SFTP in Parallel Multicast branches

2015-04-20 Thread lakshmi.prashant
Hi, We have another example of data corruption with Parallel Multicast. This issue is there even in camel-core 2.14.2. If we change to serial multicast, the issue disappears. I have a route with a camel producer (to uri) that writes data in the exchange & this data is of type stream cache

Re: Data Corruption in SFTP in Parallel Multicast branches

2015-01-26 Thread Franz Paul Forsthofer
Hello Lakshmi and Stephan, I created the bug https://issues.apache.org/jira/browse/CAMEL-8284 It does contain a solution proposal. Please have a look. Regards Franz On Fri, Jan 16, 2015 at 8:46 AM, lakshmi.prashant wrote: > Hi Stephan, > >The body of the main exchange should be copied to t

RE: Data Corruption in SFTP in Parallel Multicast branches

2015-01-16 Thread Siano, Stephan
: users@camel.apache.org Subject: RE: Data Corruption in SFTP in Parallel Multicast branches Hi Stephan, The body of the main exchange should be copied to the branch exchanges, as intended (Option 2 suggested by you). But I am not sure if it will lead to performance / memory issues, if there

RE: Data Corruption in SFTP in Parallel Multicast branches

2015-01-15 Thread lakshmi.prashant
Hi Stephan, The body of the main exchange should be copied to the branch exchanges, as intended (Option 2 suggested by you). But I am not sure if it will lead to performance / memory issues, if there are more branches with huge data in the body of the main route. Thanks, Lakshmi -- Vi

RE: Data Corruption in SFTP in Parallel Multicast branches

2015-01-14 Thread Siano, Stephan
Hi, I have had a look into the source code: If you look into the StreamCacheConverter an InputSteam will create a StreamCache object by copying the data to a CachedOutputStream and then calling the newStreamCache() method. That will generate a FileInputStreamCache or a ByteArrayStreamCache. Bo