Class AppendingMessageAggregator
- java.lang.Object
-
- com.adaptris.core.services.aggregator.MessageAggregatorImpl
-
- com.adaptris.core.services.aggregator.AppendingMessageAggregator
-
- All Implemented Interfaces:
MessageAggregator
@ComponentProfile(summary="MessageAggregator that appends all payloads to the original", since="3.9.1") public class AppendingMessageAggregator extends MessageAggregatorImpl
Implementation ofMessageAggregator
that just appends payloads.This simply iterates over each of the messages; and appends their payloads to the original message. No checking is done of the payloads; it is a raw append using a stream copy.
In the adapter configuration file this class is aliased as appending-message-aggregator 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.MessageAggregatorImpl
log
-
-
Constructor Summary
Constructors Constructor Description AppendingMessageAggregator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
aggregate(AdaptrisMessage orig, java.lang.Iterable<AdaptrisMessage> msgs)
Joins multipleAdaptrisMessage
s into a single AdaptrisMessage objects.void
joinMessage(AdaptrisMessage orig, java.util.Collection<AdaptrisMessage> toAggregate)
Joins multipleAdaptrisMessage
s into a single AdaptrisMessage objects.-
Methods inherited from class com.adaptris.core.services.aggregator.MessageAggregatorImpl
filter, filter, getFilterCondition, getOverwriteMetadata, getRetainFilterExceptionsMessages, overwriteMetadata, overwriteMetadata, setFilterCondition, setOverwriteMetadata, setRetainFilterExceptionsMessages, withOverwriteMetadata
-
-
-
-
Method Detail
-
joinMessage
public void joinMessage(AdaptrisMessage orig, java.util.Collection<AdaptrisMessage> toAggregate) throws CoreException
Description copied from interface:MessageAggregator
Joins multiple
AdaptrisMessage
s into a single AdaptrisMessage objects. Preservation of metadata is down to the implementation.- Parameters:
orig
- the msg to insert all the messages intotoAggregate
- the list of messages to join.- Throws:
CoreException
- wrapping any other exception
-
aggregate
public void aggregate(AdaptrisMessage orig, java.lang.Iterable<AdaptrisMessage> msgs) throws CoreException
Description copied from interface:MessageAggregator
Joins multiple
AdaptrisMessage
s into a single AdaptrisMessage objects. Preservation of metadata is down to the implementation.- Parameters:
orig
- the original messagemsgs
- the list of messages to join.- Throws:
CoreException
-
-