<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0">
<bean id="ftpConnectionFactory" class="org.apache.camel.component.file.remote.FtpComponent">
<property name="username" value="your_ftp_username"/>
<property name="password" value="your_ftp_password"/>
<property name="binary" value="true"/>
<property name="passiveMode" value="true"/>
</bean>
<bean id="ftp" class="org.apache.camel.component.file.remote.FtpEndpoint">
<property name="ftpClient" ref="ftpClient"/>
<property name="destinationName" value="your_ftp_server"/>
</bean>
<bean id="ftpClient" class="org.apache.commons.net.ftp.FTPClient"/>
<camelContext xmlns="http://camel.apache.org/schema/blueprint">
<route>
<from uri="ftp:your_ftp_directory?delete=true"/>
<to uri="file:your_local_directory"/>
</route>
</camelContext>
</blueprint>
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
public class FtpLibrary {
public static void main(String[] args) {
CamelContext context = new DefaultCamelContext();
try {
context.addRoutes(new RouteBuilder() {
public void configure() {
from("ftp:your_ftp_directory?delete=true")
.to("file:your_local_directory");
}
});
context.start();
context.stop();
} catch (Exception e) {
e.printStackTrace();
}
}
}
