@ComponentProfile(summary="Aggregate multiple messages into a JSON Array", since="3.6.5", tag="json") public class JsonArrayAggregator extends MessageAggregatorImpl
MessageAggregator
implementation that adds each message to a JSON array.
The pre-split message is always ignored; the payloads from the collection are assumed to be JSON objects, and will be aggregated together as a single JSON array. Messages that are not JSON objects will be ignored (JSON Arrays will also be ignored).
In the adapter configuration file this class is aliased as json-array-aggregator which is the preferred alternative to the fully qualified classname when building your configuration.
filterCondition, retainFilterExceptionsMessages
Constructor and Description |
---|
JsonArrayAggregator() |
Modifier and Type | Method and Description |
---|---|
void |
joinMessage(AdaptrisMessage original,
java.util.Collection<AdaptrisMessage> messages) |
filter, filter, getFilterCondition, getOverwriteMetadata, getRetainFilterExceptionsMessages, overwriteMetadata, overwriteMetadata, retainFilterExceptionsMessages, setFilterCondition, setOverwriteMetadata, setRetainFilterExceptionsMessages, withOverwriteMetadata
public void joinMessage(AdaptrisMessage original, java.util.Collection<AdaptrisMessage> messages) throws CoreException
CoreException