org.ikasan.component.endpoint.filesystem.messageprovider

Class FileMessageProvider

java.lang.Object

org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

All Implemented Interfaces:

MessageProvider<List<File>>, EndpointListener<String,IOException>, Configured<FileConsumerConfiguration>, ManagedResource

public class FileMessageProvider
extends Object
implements MessageProvider<List<File>>, ManagedResource, Configured<FileConsumerConfiguration>, EndpointListener<String,IOException>

Implementation of a MessageProvider based on returning a list of File references.

Author:

Ikasan Development Team

Constructor Summary

Constructors

Constructor and Description
FileMessageProvider()

Method Summary

Methods

Modifier and Type	Method and Description
FileConsumerConfiguration	getConfiguration()
protected FileMatcher	getFileMatcher(String fullyQualifiedFilename)
List<File>	invoke(org.quartz.JobExecutionContext context)
boolean	isActive()
boolean	isCriticalOnStartup()
void	onException(IOException throwable)
void	onMessage(String filename)
void	setConfiguration(FileConsumerConfiguration fileConsumerConfiguration)
void	setCriticalOnStartup(boolean criticalOnStartup)
void	setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)
void	setMessageProviderPostProcessor(MessageProviderPostProcessor messageProviderPostProcessor)
void	startManagedResource()
void	stopManagedResource()

Methods inherited from class java.lang.Object

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

Constructor Detail

FileMessageProvider

public FileMessageProvider()

Method Detail

invoke

public List<File> invoke(org.quartz.JobExecutionContext context)

Specified by:

invoke in interface MessageProvider<List<File>>

setMessageProviderPostProcessor

public void setMessageProviderPostProcessor(MessageProviderPostProcessor messageProviderPostProcessor)

getConfiguration

public FileConsumerConfiguration getConfiguration()

Specified by:

getConfiguration in interface Configured<FileConsumerConfiguration>

setConfiguration

public void setConfiguration(FileConsumerConfiguration fileConsumerConfiguration)

Specified by:

setConfiguration in interface Configured<FileConsumerConfiguration>

getFileMatcher

protected FileMatcher getFileMatcher(String fullyQualifiedFilename)

onMessage

public void onMessage(String filename)

Specified by:

onMessage in interface EndpointListener<String,IOException>

onException

public void onException(IOException throwable)

Specified by:

onException in interface EndpointListener<String,IOException>

isActive

public boolean isActive()

Specified by:

isActive in interface EndpointListener<String,IOException>

startManagedResource

public void startManagedResource()

Specified by:

startManagedResource in interface ManagedResource

stopManagedResource

public void stopManagedResource()

Specified by:

stopManagedResource in interface ManagedResource

setManagedResourceRecoveryManager

public void setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)

Specified by:

setManagedResourceRecoveryManager in interface ManagedResource

isCriticalOnStartup

public boolean isCriticalOnStartup()

Specified by:

isCriticalOnStartup in interface ManagedResource

setCriticalOnStartup

public void setCriticalOnStartup(boolean criticalOnStartup)

Specified by:

setCriticalOnStartup in interface ManagedResource