com.adaptris.core.json.aggregator

Class JsonArrayAggregator

java.lang.Object

com.adaptris.core.services.aggregator.MessageAggregatorImpl

com.adaptris.core.json.aggregator.JsonArrayAggregator

All Implemented Interfaces:

MessageAggregator

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).

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.

Constructor Summary

Constructors

Constructor and Description
JsonArrayAggregator()

Method Summary

Modifier and Type	Method and Description
void	joinMessage(AdaptrisMessage original, java.util.Collection<AdaptrisMessage> messages)

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

getOverwriteMetadata, overwriteMetadata, overwriteMetadata, setOverwriteMetadata

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

joinMessage

public void joinMessage(AdaptrisMessage original,
                        java.util.Collection<AdaptrisMessage> messages)
                 throws CoreException

Throws:

CoreException