@ComponentProfile(summary="Aggregate messages that are JSON Arrays.", since="3.6.5", tag="json") public class JsonArrayArrayAggregator 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 array or objects, and will be aggregated together as a single JSON array. Messages that are not JSON array or objects will be ignored .
In the adapter configuration file this class is aliased as json-array-array-aggregator which is the preferred alternative to the fully qualified classname when building your configuration.
filterCondition, retainFilterExceptionsMessages
Constructor and Description |
---|
JsonArrayArrayAggregator() |
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