public abstract class MessageAggregatorImpl extends java.lang.Object implements MessageAggregator
MessageAggregator
.Modifier and Type | Field and Description |
---|---|
protected Condition |
filterCondition |
protected org.slf4j.Logger |
log |
protected java.lang.Boolean |
retainFilterExceptionsMessages |
Constructor and Description |
---|
MessageAggregatorImpl() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
filter(AdaptrisMessage message) |
protected java.util.Collection<AdaptrisMessage> |
filter(java.util.Collection<AdaptrisMessage> messages) |
Condition |
getFilterCondition() |
java.lang.Boolean |
getOverwriteMetadata() |
java.lang.Boolean |
getRetainFilterExceptionsMessages() |
protected boolean |
overwriteMetadata() |
protected void |
overwriteMetadata(AdaptrisMessage src,
AdaptrisMessage target) |
java.lang.Boolean |
retainFilterExceptionsMessages() |
void |
setFilterCondition(Condition filterCondition) |
void |
setOverwriteMetadata(java.lang.Boolean b)
Whether or not to overwrite original metadata with metadata from the split messages.
|
void |
setRetainFilterExceptionsMessages(java.lang.Boolean retainFilterExceptionsMessages) |
<T extends MessageAggregatorImpl> |
withOverwriteMetadata(java.lang.Boolean b) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
joinMessage
protected transient org.slf4j.Logger log
protected Condition filterCondition
protected java.lang.Boolean retainFilterExceptionsMessages
protected java.util.Collection<AdaptrisMessage> filter(java.util.Collection<AdaptrisMessage> messages)
protected boolean filter(AdaptrisMessage message)
public java.lang.Boolean getOverwriteMetadata()
public void setOverwriteMetadata(java.lang.Boolean b)
b
- the overwriteMetadata to set, default is null (false)public <T extends MessageAggregatorImpl> T withOverwriteMetadata(java.lang.Boolean b)
protected boolean overwriteMetadata()
protected void overwriteMetadata(AdaptrisMessage src, AdaptrisMessage target)
public Condition getFilterCondition()
public void setFilterCondition(Condition filterCondition)
public java.lang.Boolean getRetainFilterExceptionsMessages()
public void setRetainFilterExceptionsMessages(java.lang.Boolean retainFilterExceptionsMessages)
public java.lang.Boolean retainFilterExceptionsMessages()