Package com.adaptris.core.services.aggregator

Class AppendingMessageAggregator

java.lang.Object

com.adaptris.core.services.aggregator.MessageAggregatorImpl

com.adaptris.core.services.aggregator.AppendingMessageAggregator

All Implemented Interfaces:

MessageAggregator

@ComponentProfile(summary="MessageAggregator that appends all payloads to the original",
                  since="3.9.1")
public class AppendingMessageAggregator
extends MessageAggregatorImpl

Implementation of MessageAggregator that just appends payloads.

This simply iterates over each of the messages; and appends their payloads to the original message. No checking is done of the payloads; it is a raw append using a stream copy.

In the adapter configuration file this class is aliased as appending-message-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
AppendingMessageAggregator()

Method Summary

Modifier and Type	Method	Description
void	aggregate(AdaptrisMessage orig, Iterable<AdaptrisMessage> msgs)	Joins multiple AdaptrisMessages into a single AdaptrisMessage objects.
void	joinMessage(AdaptrisMessage orig, Collection<AdaptrisMessage> toAggregate)	Joins multiple AdaptrisMessages into a single AdaptrisMessage objects.

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 Details

AppendingMessageAggregator

public AppendingMessageAggregator()

Method Details

joinMessage

public void joinMessage(AdaptrisMessage orig,
 Collection<AdaptrisMessage> toAggregate)
                 throws CoreException

Description copied from interface: MessageAggregator

Joins multiple AdaptrisMessages into a single AdaptrisMessage objects. Preservation of metadata is down to the implementation.

Parameters:

orig - the msg to insert all the messages into

toAggregate - the list of messages to join.

Throws:

CoreException - wrapping any other exception

aggregate

public void aggregate(AdaptrisMessage orig,
 Iterable<AdaptrisMessage> msgs)
               throws CoreException

Description copied from interface: MessageAggregator

Joins multiple AdaptrisMessages into a single AdaptrisMessage objects. Preservation of metadata is down to the implementation.

Parameters:

orig - the original message

msgs - the list of messages to join.

Throws:

CoreException