Package com.adaptris.core.services.aggregator

Class NullMessageAggregator

java.lang.Object

com.adaptris.core.services.aggregator.NullMessageAggregator

All Implemented Interfaces:

MessageAggregator

public class NullMessageAggregator
extends java.lang.Object
implements MessageAggregator

Special implementation of MessageAggregator that does not aggregate messages.

Although an edge case; it might be that you are using this as part of a PooledSplitJoinService and you simply wish to keep the original message and ignore everything else. This aggregator has an empty joinMessage(AdaptrisMessage, Collection) and aggregate(AdaptrisMessage, Iterable) method.

Since:

3.0.3

In the adapter configuration file this class is aliased as null-message-aggregator which is the preferred alternative to the fully qualified classname when building your configuration.

Constructor Summary

Constructors

Constructor	Description
NullMessageAggregator()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NullMessageAggregator

public NullMessageAggregator()

Method Detail

joinMessage

public void joinMessage(AdaptrisMessage msg,
                        java.util.Collection<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.

Specified by:

joinMessage in interface MessageAggregator

Parameters:

msg - the msg to insert all the messages into

msgs - the list of messages to join.

Throws:

CoreException - wrapping any other exception

aggregate

public void aggregate(AdaptrisMessage msg,
                      java.lang.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.

Specified by:

aggregate in interface MessageAggregator

Parameters:

msg - the original message

msgs - the list of messages to join.

Throws:

CoreException