Class JsonAggregatorImpl
java.lang.Object
com.adaptris.core.services.aggregator.MessageAggregatorImpl
com.adaptris.core.json.aggregator.JsonAggregatorImpl
- All Implemented Interfaces:
MessageAggregator
- Direct Known Subclasses:
JsonArrayAggregator
,JsonArrayArrayAggregator
,JsonMergeAggregator
-
Field Summary
Fields inherited from class com.adaptris.core.services.aggregator.MessageAggregatorImpl
log
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionabstract void
aggregate
(AdaptrisMessage original, Iterable<AdaptrisMessage> msgs) void
joinMessage
(AdaptrisMessage original, Collection<AdaptrisMessage> messages) Methods inherited from class com.adaptris.core.services.aggregator.MessageAggregatorImpl
filter, filter, getFilterCondition, getOverwriteMetadata, getRetainFilterExceptionsMessages, overwriteMetadata, overwriteMetadata, setFilterCondition, setOverwriteMetadata, setRetainFilterExceptionsMessages, withOverwriteMetadata
-
Constructor Details
-
JsonAggregatorImpl
public JsonAggregatorImpl()
-
-
Method Details
-
joinMessage
public void joinMessage(AdaptrisMessage original, Collection<AdaptrisMessage> messages) throws CoreException - Throws:
CoreException
-
aggregate
public abstract void aggregate(AdaptrisMessage original, Iterable<AdaptrisMessage> msgs) throws CoreException - Throws:
CoreException
-