CODEWITHSUNDEEP
esbtalend
RoflWaffle17
RoflWaffle17

Reputation: 191

Totally new to Talend ESB

I'm completely brand new to Talend ESB (not so much Talend for data integration, but ESB totally.)

That being said, I'm trying to build a simple route that watches a specific file path and get the filename of any file dropped into it. Then it will pass that filename to the childjob (cTalendJob) and the child job will do something to the file.

I'm able to watch the directory, procure the filename itself and System.out.println the filename. but I can't seem to 'pass' it down to the child job. When it runs, the route goes into an endless loop.enter image description here

Any help is GREATLY appreciated.

Upvotes: 0

Views: 994

Answers (2)

Screwtape
Screwtape

Reputation: 1367

I think you are making this more difficult than you need...

I don't think you need your cProcessor or cSetBody steps.

In your tRouteInput if you want the filename, then map "${header.CamelFileName}" to a field in your schema, and you will get the filename. Mapping "${in.body}" would give you the file contents, but if you don't need that you can just map the required heading. If your job would read the file as a whole, you could skip that step and just map the message body.

Also, check the default behaviour of the camel file component - it is intended to put the contents of the file into a message, moving the file to a .camel subdirectory once complete. If your job writes to the directory cFile is monitoring, it will keep running indefinitely, as it keeps finding a "new" file - you would want to write any updated files to a different directory, or a filename mask that isn't monitored by the cFile component.

Upvotes: 0

Ibrahim Mezouar
Ibrahim Mezouar

Reputation: 4061

You must add a context parameter to your Talend job, and then pass the filename from the route to the job by assigning it to the parameter. In my example I added a parameter named "Param" to my job. In the Context Param view of cTalendJob, click the + button and select it from the list of available parameters, and assign a value to it.

enter image description here

You can then do context.Param in your child job to use the filename.

Upvotes: 0

Related Questions