topic Re: How to implement GenericFileProcessStrategy in Talend route? in Talend Studio

How to implement GenericFileProcessStrategy in Talend route?

Anonymous — Thu, 23 May 2013 09:47:07 GMT

Hello all of you,
In one of my Talend Route, I have to wait for certain criterias (such as the number, names and types of files) before starting consuming all the files stored in my directory.
I saw it was possible to customize the file process strategy in Camel File Component (Cf. "processStrategy" option), what is, I assume, exactly what I should do to achieve my goal.
The only problem is I don't know how to implement this class (in the beans?), and how to declare it and use it in my route. I've tried to search the documentation and the web for some examples or tutos, but didn't find. Has anyone done this before, or know where I could find some help?
Thanks in advance!

Re: How to implement GenericFileProcessStrategy in Talend route?

Anonymous — Fri, 24 May 2013 08:18:43 GMT

Yes, you can provide the class in beans, for example, if you don't want to process the file if it names as a.txt, you can create a Bean in Beans like below:

public class CustomFileProcessStrategy extends GenericFileProcessStrategySupport<File>{
	@Override
	public boolean begin(GenericFileOperations<File> operations,
			GenericFileEndpoint<File> endpoint, Exchange exchange,
			GenericFile<File> file) throws Exception {
		boolean begin = super.begin(operations, endpoint, exchange, file);
		if(!begin){
			return false;
		}
		File realFile = file.getFile();
		if(realFile == null || !realFile.exists()){
			return false;
		}
		if("a.txt".equals(realFile.getName())){
			return false;
		}
		return true;
		
	}
}

Then according to you studio version:
Before V5.3, you can do it as below:
1. Create a cBeanRegister component, specify the id as fileStrategy, specify the Class Name as beans.CustomFileProcessStrategy
2. On cFile component, specify the Path on Basic settings, and specify the processStrategy with value #fileStrategy on Advanced settings
That's it.
On V5.3, you can replace cBeanRegister by using spring configuration, add below bean definition into Spring configuration:

<bean class="beans.CustomFileProcessStrategy" id="fileStrategy" />

That's it.

Re: How to implement GenericFileProcessStrategy in Talend route?

Anonymous — Fri, 24 May 2013 11:00:09 GMT

Thanks for your help, Gliu. It works perfectly!!! So, now, I can do almost everything
To complete Gliu's answer, here is the list of imports you have to add in the class to get it work properly:

import java.io.File;
import org.apache.camel.Exchange;
import org.apache.camel.component.file.GenericFile;
import org.apache.camel.component.file.GenericFileEndpoint;
import org.apache.camel.component.file.GenericFileOperations;
import org.apache.camel.component.file.strategy.GenericFileProcessStrategySupport;

Re: How to implement GenericFileProcessStrategy in Talend route?

Anonymous — Wed, 23 Apr 2014 10:48:01 GMT

When trying with 'Customized' java code in cbeanRegister component, getting "beans.FtpFileFilter cannot be resolved" error .Below is My 'Customized' java code :
"beanInstance = new beans.FtpFileFilter(context.filecontains);"
Could you please help me on this issue ?
How to use the Customized java code to create beanInstance in cbeanRegister component?