Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
From: "Mills, Gary (GE Digital)" <gary.L.mills@ge.com>
To: "users@camel.apache.org" <users@camel.apache.org>
Subject: camel ftp producer autocreate 2.15
Thread-Topic: camel ftp producer autocreate 2.15
Thread-Index: AdG4VakFs9zcnTuYQL+JcwwKHsvSUg==
Date: Fri, 27 May 2016 20:23:43 +0000
Message-ID: <432B2D5A72ED8747AF3452FB7E9DF6FE97848D@ALPURAPA01.e2k.ad.ge.com>
Accept-Language: en-US
Content-Language: en-US
Content-Type: multipart/alternative;
	boundary="_000_432B2D5A72ED8747AF3452FB7E9DF6FE97848DALPURAPA01e2kadge_"
MIME-Version: 1.0
archived-at: Fri, 27 May 2016 20:24:08 -0000

--_000_432B2D5A72ED8747AF3452FB7E9DF6FE97848DALPURAPA01e2kadge_
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

Hello fellow Camel's

-          Thanks in advance !!!

-
I have a question. My problem is I need to take files from message queue tr=
ansform them, rename them, and populate an ftp server with the directory st=
ructure and files, that will be transferred to another server file share mo=
unted on a cloud server.

The problem is creating the directory structure and renaming the files bein=
g produced on the ftp site. I'm using camel 2.15.


                  <aggregate strategyRef=3D"csvOutputMapAggregationStrategy=
" completionTimeout=3D"45000" >  <!-- 30000 -->
                  <correlationExpression>
                      <header>correlationId</header>
                  </correlationExpression>
                  <completionPredicate>
                      <simple>${body.totalParameterCount} =3D=3D ${in.heade=
r.parameterCountByAsset[${in.header.enginePosition}]}</simple>
                  </completionPredicate>
                      <log message=3D"Marshalling FADEC data to CSV for air=
craft ${header.aircraftMetadata.shipNumber} fleet ${header.aircraftMetadata=
.fleetName} asset GUID ${header.engineGuid}" loggingLevel=3D"INFO"/>
                      <process ref=3D"csvMarshallerProcessor"/>
                      <to uri=3D"{{outputArchiveUri}}?fileName=3D${header.e=
ngineGuid}_${header.messageDateTime}.txt&amp;charset=3D{{outputEncoding}}"/=
>
                      <to uri=3D"{{cifsUri}}fileName=3D/${header.aircraftMe=
tadata.outputPath}/${header.engineGuid}_${header.messageDateTime}.txt&amp;c=
harset=3D{{outputEncoding}}"/>
                      <log message=3D"FILE NAME: /${header.aircraftMetadata=
.outputPath}/${header.engineGuid}_${header.messageDateTime}.txt" loggingLev=
el=3D"INFO" />

                      <!-- <to uri=3D"{{DeltaPreProdFTP}}fileName=3D${heade=
r.aircraftMetadata.outputPath}/${header.engineGuid}_${header.messageDateTim=
e}.txt&amp;charset=3D{{outputEncoding}}" /> -->
                      <to uri=3D"ftp://smartsignal@ftp.corporate.ge.com/$si=
mple{header.aircraftMetadata.outputPath}/$simple{header.engineGuid}_$simple=
{header.messageDateTime}.txt?password=3DRAW(NTM1MjBhMm)&amp;move=3D.process=
ed&amp;readLock=3Dchanged&amp;disconnect=3Dtrue&amp;stepwise=3Dfalse&amp;us=
eList=3Dfalse" />

                      <log message=3D"FADEC processing complete for aircraf=
t ${header.aircraftMetadata.shipNumber} fleet ${header.aircraftMetadata.fle=
etName} asset GUID ${header.engineGuid}" loggingLevel=3D"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  ( th=
is 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: ${hea=
der.aircraftMetadata.outputPath}/${header.engineGuid}_${header.messageDateT=
ime}.txt/null-destination--ID-414d5120544f51313150524420202020f934e856a1819=
526


--_000_432B2D5A72ED8747AF3452FB7E9DF6FE97848DALPURAPA01e2kadge_--