Class JsonArrayAggregator
java.lang.Object
com.adaptris.core.services.aggregator.MessageAggregatorImpl
com.adaptris.core.json.aggregator.JsonAggregatorImpl
com.adaptris.core.json.aggregator.JsonArrayAggregator
- All Implemented Interfaces:
MessageAggregator
@ComponentProfile(summary="Aggregate multiple messages into a JSON Array",
since="3.6.5",
tag="json")
public class JsonArrayAggregator
extends JsonAggregatorImpl
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).
- Since:
- 3.6.5
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.
-
Field Summary
Fields inherited from class com.adaptris.core.services.aggregator.MessageAggregatorImpl
log
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
aggregate
(AdaptrisMessage original, Iterable<AdaptrisMessage> messages) Methods inherited from class com.adaptris.core.json.aggregator.JsonAggregatorImpl
joinMessage
Methods inherited from class com.adaptris.core.services.aggregator.MessageAggregatorImpl
filter, filter, getFilterCondition, getOverwriteMetadata, getRetainFilterExceptionsMessages, overwriteMetadata, overwriteMetadata, setFilterCondition, setOverwriteMetadata, setRetainFilterExceptionsMessages, withOverwriteMetadata
-
Constructor Details
-
JsonArrayAggregator
public JsonArrayAggregator()
-
-
Method Details
-
aggregate
public void aggregate(AdaptrisMessage original, Iterable<AdaptrisMessage> messages) throws CoreException - Specified by:
aggregate
in interfaceMessageAggregator
- Specified by:
aggregate
in classJsonAggregatorImpl
- Throws:
CoreException
-