Package com.adaptris.core.json.aggregator

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

Constructors

Constructor	Description
JsonArrayAggregator()

Method Summary

Modifier and Type	Method	Description
void	aggregate(AdaptrisMessage original, java.lang.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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JsonArrayAggregator

public JsonArrayAggregator()

Method Detail

aggregate

public void aggregate(AdaptrisMessage original,
                      java.lang.Iterable<AdaptrisMessage> messages)
               throws CoreException

Specified by:

aggregate in interface MessageAggregator

Specified by:

aggregate in class JsonAggregatorImpl

Throws:

CoreException