org.springframework.integration.file.monitors
Class AbstractEventDrivenFileMonitor

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.file.monitors.AbstractEventDrivenFileMonitor

All Implemented Interfaces:

BeanFactoryAware, BeanNameAware, InitializingBean, NamedComponent, EventDrivenDirectoryMonitor

Direct Known Subclasses:

DirectedEventDrivenFileMonitor

public abstract class AbstractEventDrivenFileMonitor
extends IntegrationObjectSupport
implements EventDrivenDirectoryMonitor

This component will support event-based (not poller based) notifications of files from a file system. Immediate implementations will center around supporting other adapters's delivery of files once they've been synced from a remote system. Potential future expansions for consumer consumption might be a push / event-based file adapter based on either native code or Java 7's NIO.2 WaterService or other third party implementations.

In the meantime, this provides us with a base class for building event driven file adapters quickly. The two cases I see are:

Author:

Josh Long

Field Summary

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

logger

Constructor Summary

AbstractEventDrivenFileMonitor()

Method Summary

protected void	installDirectoryIfRequired(File directoryToMonitor) Handles ensuring that the directory we're monitroring exists or can be created
void	monitor(File directory, FileAdditionListener fileAdditionListener) installs directory, and then kicks of an event pump
protected void	onInit() Subclasses may implement this for initialization logic.
protected void	prescan() Obviously, we're trying to keep away from scanning, but this may be necessary at startup to catch up the backlog
protected void	publishNewFileReceived(File file)
protected void	publishNewFileReceived(String path)
void	setAutoCreateDirectory(boolean autoCreateDirectory)
void	setExecutor(Executor executor)
void	setFilter(EntryListFilter<File> filter)
void	setMaxQueueSize(int maxQueueSize)
void	setScanDirectoryOnLoad(boolean scanDirectoryOnLoad)
protected void	start() Custom initialization hook - override at your discretion

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractEventDrivenFileMonitor

public AbstractEventDrivenFileMonitor()

Method Detail

setScanDirectoryOnLoad

public void setScanDirectoryOnLoad(boolean scanDirectoryOnLoad)

monitor

public void monitor(File directory,
                    FileAdditionListener fileAdditionListener)
             throws Exception

installs directory, and then kicks of an event pump

Specified by:

monitor in interface EventDrivenDirectoryMonitor

Parameters:

directory - the directory to start watching from. Unspecified if this implies recursion or not.

fileAdditionListener - the callback

Throws:

Exception

setMaxQueueSize

public void setMaxQueueSize(int maxQueueSize)

setFilter

public void setFilter(EntryListFilter<File> filter)

setExecutor

public void setExecutor(Executor executor)

setAutoCreateDirectory

public void setAutoCreateDirectory(boolean autoCreateDirectory)

publishNewFileReceived

protected void publishNewFileReceived(String path)

publishNewFileReceived

protected void publishNewFileReceived(File file)

prescan

protected void prescan()

Obviously, we're trying to keep away from scanning, but this may be necessary at startup to catch up the backlog

installDirectoryIfRequired

protected void installDirectoryIfRequired(File directoryToMonitor)
                                   throws Exception

Handles ensuring that the directory we're monitroring exists or can be created

Parameters:

directoryToMonitor - the directory to monitor

Throws:

Exception

start

protected void start()
              throws Exception

Custom initialization hook - override at your discretion

Throws:

Exception

onInit

protected void onInit()
               throws Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

Throws:

Exception