org.springframework.integration.adapter.file
Class FileSource

java.lang.Object
  org.springframework.integration.adapter.file.FileSource

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, MessageDeliveryAware, Source<java.lang.Object>

public class FileSource
extends java.lang.Object
implements Source<java.lang.Object>, org.springframework.beans.factory.InitializingBean, MessageDeliveryAware

A messaging source that polls a directory to retrieve files.

Author:

Mark Fisher, Marius Bogoevici

Field Summary

private java.io.File	directory
private DirectoryContentManager	directoryContentManager
private java.io.FileFilter	fileFilter
private java.io.FilenameFilter	filenameFilter
private org.apache.commons.logging.Log	logger
private MessageCreator<java.io.File,?>	messageCreator

Constructor Summary

FileSource(java.io.File directory)

FileSource(java.io.File directory, MessageCreator<java.io.File,?> messageCreator)

Method Summary

void	afterPropertiesSet()
void	onFailure(MessagingException exception) Callback method invoked after a message delivery failure.
void	onSend(Message<?> message) Callback method invoked after a message is sent successfully.
Message	receive() Retrieve a message from this source or null if no message is available.
void	setFileFilter(java.io.FileFilter fileFilter)
void	setFilenameFilter(java.io.FilenameFilter filenameFilter)
void	setMessageCreator(MessageCreator<java.io.File,?> messageCreator)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private final org.apache.commons.logging.Log logger

directory

private final java.io.File directory

messageCreator

private volatile MessageCreator<java.io.File,?> messageCreator

fileFilter

private volatile java.io.FileFilter fileFilter

filenameFilter

private volatile java.io.FilenameFilter filenameFilter

directoryContentManager

private final DirectoryContentManager directoryContentManager

Constructor Detail

FileSource

public FileSource(java.io.File directory)

FileSource

public FileSource(java.io.File directory,
                  MessageCreator<java.io.File,?> messageCreator)

Method Detail

setMessageCreator

public void setMessageCreator(MessageCreator<java.io.File,?> messageCreator)

setFileFilter

public void setFileFilter(java.io.FileFilter fileFilter)

setFilenameFilter

public void setFilenameFilter(java.io.FilenameFilter filenameFilter)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

receive

public Message receive()

Description copied from interface: Source

Retrieve a message from this source or null if no message is available.

Specified by:

receive in interface Source<java.lang.Object>

onSend

public void onSend(Message<?> message)

Description copied from interface: MessageDeliveryAware

Callback method invoked after a message is sent successfully.

Specified by:

onSend in interface MessageDeliveryAware

onFailure

public void onFailure(MessagingException exception)

Description copied from interface: MessageDeliveryAware

Callback method invoked after a message delivery failure.

Specified by:

onFailure in interface MessageDeliveryAware