AggregatingConsumer (Interlok Core/Base)

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
  
  All Methods Instance Methods Abstract Methods
  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 Detail
  - 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