Package com.adaptris.core.services.aggregator

Class MessageAggregatorImpl

java.lang.Object

com.adaptris.core.services.aggregator.MessageAggregatorImpl

All Implemented Interfaces:

MessageAggregator

Direct Known Subclasses:

AppendingMessageAggregator, MimeAggregator, MultiPayloadMessageAggregator, ReplaceWithFirstMessage, XmlDocumentAggregator, ZipAggregator

public abstract class MessageAggregatorImpl
extends java.lang.Object
implements MessageAggregator

Abstract implementation of MessageAggregator.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
MessageAggregatorImpl()

Method Summary

Modifier and Type	Method	Description
protected boolean	filter(AdaptrisMessage message)
protected java.util.Collection<AdaptrisMessage>	filter(java.util.Collection<AdaptrisMessage> messages)
Condition	getFilterCondition()	Allows you to filter the messages based on a condition - optional, positive filter match
java.lang.Boolean	getOverwriteMetadata()	Whether or not to overwrite original metadata with metadata from the split messages.
java.lang.Boolean	getRetainFilterExceptionsMessages()	Should an error occur with the filter, should we exclude these messages from the result?
protected boolean	overwriteMetadata()
protected void	overwriteMetadata(AdaptrisMessage src, AdaptrisMessage target)
void	setFilterCondition(Condition filterCondition)	Allows you to filter the messages based on a condition - optional, positive filter match
void	setOverwriteMetadata(java.lang.Boolean overwriteMetadata)	Whether or not to overwrite original metadata with metadata from the split messages.
void	setRetainFilterExceptionsMessages(java.lang.Boolean retainFilterExceptionsMessages)	Should an error occur with the filter, should we exclude these messages from the result?
<T extends MessageAggregatorImpl> T	withOverwriteMetadata(java.lang.Boolean b)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.services.aggregator.MessageAggregator

aggregate, joinMessage

Field Detail

log

protected transient org.slf4j.Logger log

Constructor Detail

MessageAggregatorImpl

public MessageAggregatorImpl()

Method Detail

filter

protected java.util.Collection<AdaptrisMessage> filter(java.util.Collection<AdaptrisMessage> messages)

filter

protected boolean filter(AdaptrisMessage message)

withOverwriteMetadata

public <T extends MessageAggregatorImpl> T withOverwriteMetadata(java.lang.Boolean b)

overwriteMetadata

protected boolean overwriteMetadata()

overwriteMetadata

protected void overwriteMetadata(AdaptrisMessage src,
                                 AdaptrisMessage target)

getOverwriteMetadata

public java.lang.Boolean getOverwriteMetadata()

Whether or not to overwrite original metadata with metadata from the split messages.

setOverwriteMetadata

public void setOverwriteMetadata(java.lang.Boolean overwriteMetadata)

Whether or not to overwrite original metadata with metadata from the split messages.

getFilterCondition

public Condition getFilterCondition()

Allows you to filter the messages based on a condition - optional, positive filter match

setFilterCondition

public void setFilterCondition(Condition filterCondition)

Allows you to filter the messages based on a condition - optional, positive filter match

getRetainFilterExceptionsMessages

public java.lang.Boolean getRetainFilterExceptionsMessages()

Should an error occur with the filter, should we exclude these messages from the result?

setRetainFilterExceptionsMessages

public void setRetainFilterExceptionsMessages(java.lang.Boolean retainFilterExceptionsMessages)

Should an error occur with the filter, should we exclude these messages from the result?