Hello fellow Camel's
- Thanks in advance !!!
-
I have a question. My problem is I need to take files from message queue
transform them, rename them, and populate an ftp server with the directory
structure and files, that will be transferred to another server file share
mounted on a cloud server.
The problem is creating the directory structure and renaming the files being
produced on the ftp site. I'm using camel 2.15.
<aggregate strategyRef="csvOutputMapAggregationStrategy"
completionTimeout="45000" > <!-- 30000 -->
<correlationExpression>
<header>correlationId</header>
</correlationExpression>
<completionPredicate>
<simple>${body.totalParameterCount} ==
${in.header.parameterCountByAsset[${in.header.enginePosition}]}</simple>
</completionPredicate>
<log message="Marshalling FADEC data to CSV for aircraft
${header.aircraftMetadata.shipNumber} fleet
${header.aircraftMetadata.fleetName} asset GUID ${header.engineGuid}"
loggingLevel="INFO"/>
<process ref="csvMarshallerProcessor"/>
<to
uri="{{outputArchiveUri}}?fileName=${header.engineGuid}_${header.messageDateTime}.txt&charset={{outputEncoding}}"/>
<to
uri="{{cifsUri}}fileName=/${header.aircraftMetadata.outputPath}/${header.engineGuid}_${header.messageDateTime}.txt&charset={{outputEncoding}}"/>
<log message="FILE NAME:
/${header.aircraftMetadata.outputPath}/${header.engineGuid}_${header.messageDateTime}.txt"
loggingLevel="INFO" />
<!-- <to
uri="{{DeltaPreProdFTP}}fileName=${header.aircraftMetadata.outputPath}/${header.engineGuid}_${header.messageDateTime}.txt&charset={{outputEncoding}}"
/> -->
<to
uri="ftp://[email protected]/$simple{header.aircraftMetadata.outputPath}/$simple{header.engineGuid}_$simple{header.messageDateTime}.txt?password=RAW(NTM1MjBhMm)&move=.processed&readLock=changed&disconnect=true&stepwise=false&useList=false"
/>
<log message="FADEC processing complete for aircraft
${header.aircraftMetadata.shipNumber} fleet
${header.aircraftMetadata.fleetName} asset GUID ${header.engineGuid}"
loggingLevel="INFO"/>
</aggregate>
</split>
The cifsUri works as we want creating the directory and renaming the file :
717-200/BB9D2AC8-3B10-479B-9823-9F0AB1197C49_2016-05-27_17.03.00.txt ( this is
because, and I think, I am ftp'ing to a mounted file share )
The DeltaPreProd or simply the uri below it, produces something like:
${header.aircraftMetadata.outputPath}/${header.engineGuid}_${header.messageDateTime}.txt/null-destination--ID-414d5120544f51313150524420202020f934e856a1819526