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 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 Collection<AdaptrisMessage>	filter(Collection<AdaptrisMessage> messages)
Condition	getFilterCondition()	Allows you to filter the messages based on a condition - optional, positive filter match
Boolean	getOverwriteMetadata()	Whether or not to overwrite original metadata with metadata from the split messages.
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(Boolean overwriteMetadata)	Whether or not to overwrite original metadata with metadata from the split messages.
void	setRetainFilterExceptionsMessages(Boolean retainFilterExceptionsMessages)	Should an error occur with the filter, should we exclude these messages from the result?
<T extends MessageAggregatorImpl> T	withOverwriteMetadata(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 Details

log

protected transient org.slf4j.Logger log

Constructor Details

MessageAggregatorImpl

public MessageAggregatorImpl()

Method Details

filter

protected Collection<AdaptrisMessage> filter(Collection<AdaptrisMessage> messages)

filter

protected boolean filter(AdaptrisMessage message)

withOverwriteMetadata

public <T extends MessageAggregatorImpl> T withOverwriteMetadata(Boolean b)

overwriteMetadata

protected boolean overwriteMetadata()

overwriteMetadata

protected void overwriteMetadata(AdaptrisMessage src,
 AdaptrisMessage target)

getOverwriteMetadata

public Boolean getOverwriteMetadata()

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

setOverwriteMetadata

public void setOverwriteMetadata(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 Boolean getRetainFilterExceptionsMessages()

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

setRetainFilterExceptionsMessages

public void setRetainFilterExceptionsMessages(Boolean retainFilterExceptionsMessages)

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