Package com.adaptris.core.services.aggregator

Interface AggregatingConsumer<T extends AggregatingConsumeService>

All Superinterfaces:

ComponentLifecycle

All Known Subinterfaces:

AggregatingJmsConsumer

All Known Implementing Classes:

AggregatingConsumerImpl, AggregatingFsConsumer, AggregatingFtpConsumer, AggregatingQueueConsumer

public interface AggregatingConsumer<T extends AggregatingConsumeService>
extends ComponentLifecycle

Consumer interface for performing aggregation.

Method Summary

Modifier and Type	Method	Description
void	aggregateMessages(AdaptrisMessage msg, T service)	Perform the aggregation.

Methods inherited from interface com.adaptris.core.ComponentLifecycle

close, init, start, stop

Method Details

aggregateMessages

void aggregateMessages(AdaptrisMessage msg,
 T service)
                throws ServiceException

Perform the aggregation.

Parameters:

msg - the current message being processed.

service - the service that relates to this consumer implementation.

Throws:

ServiceException