Package com.adaptris.core.json.aggregator

Class JsonArrayArrayAggregator

java.lang.Object

com.adaptris.core.services.aggregator.MessageAggregatorImpl

com.adaptris.core.json.aggregator.JsonAggregatorImpl

com.adaptris.core.json.aggregator.JsonArrayArrayAggregator

All Implemented Interfaces:

MessageAggregator

@ComponentProfile(summary="Aggregate messages that are JSON Arrays.",
                  since="3.6.5",
                  tag="json")
public class JsonArrayArrayAggregator
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 array or objects, and will be aggregated together as a single JSON array. Messages that are not JSON array or objects will be ignored .

Since:

3.6.5

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.

Field Summary

Fields inherited from class com.adaptris.core.services.aggregator.MessageAggregatorImpl

log

Constructor Summary

Constructors

Constructor	Description
JsonArrayArrayAggregator()

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

JsonArrayArrayAggregator

public JsonArrayArrayAggregator()

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