When multiple producers are used to consume input from a consumer, the exchange object available to only one producer.
Issue
- When multiple producers are used to consume input from a file consumer, the exchange object available to only one producer.
- Currently, we are encountering an issue where alert emails are being falsely sent out. The files have been successfully transferred to the destinations but somehow, there is a residual of it present which causes this. We are not able to pin-point the root cause of this 'bogus' email issue and need some help.
- An example of a route from the Management Console
<route xmlns="http://camel.apache.org/schema/spring" id="Inbound">
<from uri="smb://xyz.com;abc@lmn.com/path/to?password=G00d2G0ld&localWorkDirectory=/path/to&scheduler=spring&scheduler.cron=0/20 * * * * ?&inProgressRepository=#inProgressRepoHazel&autoCreate=false&delete=true&include=.*.dat"/>
<onException>
<redeliveryPolicy maximumRedeliveries="72" redeliveryDelay="3600000" retryAttemptedLogLevel="INFO"/>
<log message="*************File: ${headers.CamelFileName} never reached destination********************" loggingLevel="INFO"/>
<log message="*************Continue Processing the file Probably can't reach destination********************" loggingLevel="INFO"/>
</onException>
<log message="Start Transfer File: ${headers.CamelFileName} , ${headers.CamelFileLength} bytes"/>
<setHeader headerName="DESTINATION_LIST">
<constant>sftp://lmn@abc.com/path/to?password=sts123&passiveMode=true&preferredAuthentications=password&eagerDeleteTargetFile=false&autoCreate=false&tempFileName=${headers.CamelFileName}-${headers.CamelFileLength}-${headers.CamelFileLastModified}_</constant>
</setHeader>
<to uri="smb://abc.com;test@xyz.abc.com/path/to?password=G00d2G0ld&eagerDeleteTargetFile=false&autoCreate=false&tempFileName=${headers.CamelFileName}-${headers.CamelFileLength}-${headers.CamelFileLastModified}_"/>
<recipientList parallelProcessing="true" streaming="true" timeout="4320000">
<expressionDefinition>tokenize(header{DESTINATION_LIST}, ~~~)</expressionDefinition>
</recipientList>
<log message="MFT-End Transfer File: ${headers.CamelFileName} , ${headers.CamelFileLength} bytes "/>
</route>
Environment
- Red Hat JBoss Fuse
- 6.1.0
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase of over 48,000 articles and solutions.
Welcome! Check out the Getting Started with Red Hat page for quick tours and guides for common tasks.
