public class  SftpConfiguration {

public DefaultSftpSessionFactory sftpFactory() {
        
        DefaultSftpSessionFactory factory=new DefaultSftpSessionFactory();
        factory.setHost("*******");
        factory.setPort(22);
        factory.setAllowUnknownKeys(true);
        factory.setUser("ishant");
        factory.setPassword("**********");
        return factory;
    }
@Bean(name="mydefaultsync")
    public SftpInboundFileSynchronizer synchronizer(){
        SftpInboundFileSynchronizer sync = new SftpInboundFileSynchronizer(sftpFactory());
        sync.setDeleteRemoteFiles(true);
        sync.setRemoteDirectory("C:/Users/ishant/Downloads");
        sync.setFilter(new SftpSimplePatternFileListFilter("*.txt"));
        sync.setPreserveTimestamp(true);
        sync.

        return sync;
    }

    @Bean(name="sftpMessageSource")
    @InboundChannelAdapter(channel="fileuploaded", poller = @Poller(fixedDelay = "5000"))
    public MessageSource<File> sftpMessageSource(){
        SftpInboundFileSynchronizingMessageSource source =
                new SftpInboundFileSynchronizingMessageSource(synchronizer());
        source.setLocalDirectory(new File("tmp/incoming"));
        source.setAutoCreateLocalDirectory(true);
        source.setMaxFetchSize(1); 
        
        System.out.println(source);
        return source;
    }

    @ServiceActivator(inputChannel = "fileuploaded")
    public void handleIncomingFile(File file) throws IOException {
        log.info(String.format("handleIncomingFile BEGIN %s", file.getName()));
        String content = FileUtils.readFileToString(file, "UTF-8");
        log.info(String.format("Content: %s", content));
        log.info(String.format("handleIncomingFile END %s", file.getName()));
    }
}