public interface MessageAggregator
AdaptrisMessage
instance from multiple
Messages.PooledSplitJoinService
Modifier and Type | Method and Description |
---|---|
default void |
aggregate(AdaptrisMessage original,
java.lang.Iterable<AdaptrisMessage> msgs)
Joins multiple
AdaptrisMessage s into a single AdaptrisMessage
objects. |
static java.util.Collection<AdaptrisMessage> |
collect(java.lang.Iterable<AdaptrisMessage> iter) |
default void |
joinMessage(AdaptrisMessage msg,
java.util.Collection<AdaptrisMessage> msgs)
Joins multiple
AdaptrisMessage s into a single AdaptrisMessage
objects. |
default void joinMessage(AdaptrisMessage msg, java.util.Collection<AdaptrisMessage> msgs) throws CoreException
Joins multiple AdaptrisMessage
s into a single AdaptrisMessage
objects. Preservation of metadata is down to the implementation.
msg
- the msg to insert all the messages intomsgs
- the list of messages to join.CoreException
- wrapping any other exceptionUnsupportedOperationException
.default void aggregate(AdaptrisMessage original, java.lang.Iterable<AdaptrisMessage> msgs) throws CoreException, java.io.IOException
Joins multiple AdaptrisMessage
s into a single AdaptrisMessage
objects. Preservation of metadata is down to the implementation.
original
- the original messagemsgs
- the list of messages to join.CoreException
java.io.IOException
joinMessage(AdaptrisMessage, Collection)
for backwards compatibility
reasons.static java.util.Collection<AdaptrisMessage> collect(java.lang.Iterable<AdaptrisMessage> iter) throws java.io.IOException, CoreException
java.io.IOException
CoreException