public interface AggregatingConsumer<T extends AggregatingConsumeService> extends ComponentLifecycle
Modifier and Type | Method and Description |
---|---|
void |
aggregateMessages(AdaptrisMessage msg,
T service)
Perform the aggregation.
|
close, init, start, stop
void aggregateMessages(AdaptrisMessage msg, T service) throws ServiceException
msg
- the current message being processed.service
- the service that relates to this consumer implementation.ServiceException