Service
implementations for aggregating messages.See: Description
Interface | Description |
---|---|
AggregatingConsumer<T extends AggregatingConsumeService> |
Consumer interface for performing aggregation.
|
AggregatingConsumeService<T extends AdaptrisConnection> |
Marker interface for all implementations of
AggregatingConsumer to use. |
ConsumeDestinationGenerator |
Generate a
ConsumeDestination based on the message currently being processed. |
MessageAggregator |
Interface for creating a single
AdaptrisMessage instance from multiple Messages. |
Class | Description |
---|---|
AggregatingConsumerImpl<E extends AggregatingConsumeService> |
Base class for
AggregatingConsumer implementations. |
AggregatingConsumeServiceImpl<E extends AdaptrisConnection> |
Base class for
AggregatingConsumeService implementations providing common functionality. |
ConsumeDestinationFromMetadata |
A
ConsumeDestinationGenerator that works with metadata. |
IgnoreOriginalMimeAggregator |
MessageAggregator implementation that creates a new mime part for each message that needs to be joined up. |
IgnoreOriginalXmlDocumentAggregator |
MessageAggregator implementation that creates single XML using each message that needs to be joined up. |
MessageAggregatorImpl |
Abstract implementation of
MessageAggregator . |
MimeAggregator |
MessageAggregator implementation that creates a new mime part for each message that needs to be joined up. |
NullMessageAggregator |
Special implementation of
MessageAggregator that does not aggregate messages. |
ReplaceWithFirstMessage |
Special implementation of
MessageAggregator that replaces the original payload with the first aggregated message. |
XmlDocumentAggregator |
MessageAggregator implementation that creates single XML using each message that needs to be joined up. |
ZipAggregator |
MessageAggregator implementation that creates single zip using each message as a file in the zip. |
Service
implementations for aggregating messages.