[CAMEL-8284] MultiCast in Parallel Processing Mode with StreamCache leads to wrong results

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.14.1
• Fix Version/s: 2.15.0
• Component/s: camel-core
• Patch Info: Patch Available
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Franz Forsthofer
• Created: 27/Jan/15 07:51
• Updated: 21/Feb/15 15:06
• Resolved: 21/Feb/15 15:06

Description

If the multi-cast processor gets as an input a stream cache in the parallel processing mode, then the stream is read by different threads concurrently. This leads to wrong results.

The attached patch solves this issue. The idea of the patch is to provide a copy of the stream cache to each thread. The copy will use the same cache of the original stream cache, only the stream which accesses the cached data will be a separate instance. For this, we introduced the new method

copy()

in the StreamCache class.

See also discussion in http://camel.465427.n5.nabble.com/Data-Corruption-in-SFTP-in-Parallel-Multicast-branches-td5761673.html#a5761781

Franz Forsthofer
SAP SE
e-mail: franz.forsthofer[at]sap.com