org.springframework.integration.ftp
Class FtpInboundRemoteFileSystemSynchronizer

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.endpoint.AbstractEndpoint
          org.springframework.integration.file.AbstractInboundRemoteFileSystemSychronizer<org.apache.commons.net.ftp.FTPFile>
              org.springframework.integration.ftp.FtpInboundRemoteFileSystemSynchronizer

All Implemented Interfaces:

BeanFactoryAware, BeanNameAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, NamedComponent

public class FtpInboundRemoteFileSystemSynchronizer
extends AbstractInboundRemoteFileSystemSychronizer<org.apache.commons.net.ftp.FTPFile>

An FTP-adapter implementation of AbstractInboundRemoteFileSystemSychronizer

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.file.AbstractInboundRemoteFileSystemSychronizer

AbstractInboundRemoteFileSystemSychronizer.EntryAcknowledgmentStrategy<T>

Field Summary

protected FtpClientPool

clientPool

Fields inherited from class org.springframework.integration.file.AbstractInboundRemoteFileSystemSychronizer

entryAcknowledgmentStrategy, filter, localDirectory, scheduledFuture, shouldDeleteSourceFile

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

FtpInboundRemoteFileSystemSynchronizer()

Method Summary

protected Trigger	getTrigger() Returns a value in millis dictating how frequently the trigger should fire
protected void	onInit() Subclasses may implement this for initialization logic.
void	setClientPool(FtpClientPool clientPool) The FtpClientPool that holds references to FTPClient instances
protected void	syncRemoteToLocalFileSystem() This is the callback where we need the implementation to do some specific work

Methods inherited from class org.springframework.integration.file.AbstractInboundRemoteFileSystemSychronizer

acknowledge, doStart, doStop, setEntryAcknowledgmentStrategy, setFilter, setLocalDirectory, setShouldDeleteSourceFile

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

clientPool

protected volatile FtpClientPool clientPool

Constructor Detail

FtpInboundRemoteFileSystemSynchronizer

public FtpInboundRemoteFileSystemSynchronizer()

Method Detail

getTrigger

protected Trigger getTrigger()

Description copied from class: AbstractInboundRemoteFileSystemSychronizer

Returns a value in millis dictating how frequently the trigger should fire

Specified by:

getTrigger in class AbstractInboundRemoteFileSystemSychronizer<org.apache.commons.net.ftp.FTPFile>

Returns:

a Trigger implementation (likely, PeriodicTrigger)

setClientPool

public void setClientPool(FtpClientPool clientPool)

The FtpClientPool that holds references to FTPClient instances

Parameters:

clientPool - the FtpClientPool

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

Throws:

java.lang.Exception

syncRemoteToLocalFileSystem

protected void syncRemoteToLocalFileSystem()

Description copied from class: AbstractInboundRemoteFileSystemSychronizer

This is the callback where we need the implementation to do some specific work

Specified by:

syncRemoteToLocalFileSystem in class AbstractInboundRemoteFileSystemSychronizer<org.apache.commons.net.ftp.FTPFile>