com.adaptris.core.fs

Class AggregatingFsConsumer

java.lang.Object

com.adaptris.core.services.aggregator.AggregatingConsumerImpl<AggregatingFsConsumeService>

com.adaptris.core.fs.AggregatingFsConsumer

All Implemented Interfaces:

ComponentLifecycle, AggregatingConsumer<AggregatingFsConsumeService>

public class AggregatingFsConsumer
extends AggregatingConsumerImpl<AggregatingFsConsumeService>

AggregatingConsumer implementation that allows you to read a separate message from the filesystem that is correlated in some way to the current message.

You need to configure a ConsumeDestinationGenerator implementation; which is subsequently used to generate the fully qualified URL to the destination message e.g. file:///C:/path/to/correlated/message. If the file does not exist, is inaccessible or not a file, then an exception is thrown.

If a filter-expression of the generated ConsumeDestination is available, then this works as a true aggregator; it will trigger the use of a FileFilter, and ultimately cause multiple files to be read and passed to the configured message aggregator. Note that no decision is made about the resulting size of the message, all messages that match the filter-expression will be aggregated; if there a 2000 files sitting in a directory that match the filter-expression, then that is how many will be picked up.

In the adapter configuration file this class is aliased as aggregating-fs-consumer which is the preferred alternative to the fully qualified classname when building your configuration.

Field Summary

Fields inherited from class com.adaptris.core.services.aggregator.AggregatingConsumerImpl

log

Constructor Summary

Constructors

Constructor and Description
AggregatingFsConsumer()
AggregatingFsConsumer(ConsumeDestinationGenerator d)

Method Summary

Modifier and Type	Method and Description
void	aggregateMessages(AdaptrisMessage msg, AggregatingFsConsumeService service) Perform the aggregation.
java.lang.Boolean	getDeleteAggregatedFiles()
AdaptrisMessageEncoder	getEncoder()
java.lang.String	getFileFilterImp()
java.lang.String	getWipSuffix()
void	setDeleteAggregatedFiles(java.lang.Boolean deleteAggregatedFiles) Set whether to delete aggregated files.
void	setEncoder(AdaptrisMessageEncoder ame) Set the encoder to use when reading files.
void	setFileFilterImp(java.lang.String classname) Set the file filter implementation that will be used.
void	setWipSuffix(java.lang.String suffix) Sets the work-in-progress suffix to use.

Methods inherited from class com.adaptris.core.services.aggregator.AggregatingConsumerImpl

close, getDestination, getMessageAggregator, init, rethrowServiceException, setDestination, setMessageAggregator, start, start, stop, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatingFsConsumer

public AggregatingFsConsumer()

AggregatingFsConsumer

public AggregatingFsConsumer(ConsumeDestinationGenerator d)

Method Detail

aggregateMessages

public void aggregateMessages(AdaptrisMessage msg,
                              AggregatingFsConsumeService service)
                       throws ServiceException

Description copied from interface: AggregatingConsumer

Perform the aggregation.

Parameters:

msg - the current message being processed.

service - the service that relates to this consumer implementation.

Throws:

ServiceException

getFileFilterImp

public java.lang.String getFileFilterImp()

Returns:

the fileFilterImp

setFileFilterImp

public void setFileFilterImp(java.lang.String classname)

Set the file filter implementation that will be used.

Parameters:

classname - the fileFilterImp to set, defaults to

getEncoder

public AdaptrisMessageEncoder getEncoder()

Returns:

the encoder

setEncoder

public void setEncoder(AdaptrisMessageEncoder ame)

Set the encoder to use when reading files.

Parameters:

ame - the encoder to set

getWipSuffix

public java.lang.String getWipSuffix()

Returns:

the wipSuffix

setWipSuffix

public void setWipSuffix(java.lang.String suffix)

Sets the work-in-progress suffix to use.

This suffix is added to the original file name while the file is being processed.

Parameters:

suffix - the wipSuffix to set, if not explicitly configured defaults to '_wip'

getDeleteAggregatedFiles

public java.lang.Boolean getDeleteAggregatedFiles()

Returns:

the deleteAggregatedFiles

setDeleteAggregatedFiles

public void setDeleteAggregatedFiles(java.lang.Boolean deleteAggregatedFiles)

Set whether to delete aggregated files.

Parameters:

deleteAggregatedFiles - defaults to true.