public class SimpleMessageGroupProcessor extends java.lang.Object implements MessageGroupProcessor
MessageGroupProcessor
that simply returns the messages in the group.
It can be used to configure an aggregator as a barrier, such that when the group
is complete, the grouped messages are released as individual messages.Constructor and Description |
---|
SimpleMessageGroupProcessor() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
processMessageGroup(MessageGroup group)
Process the given MessageGroup.
|
public java.lang.Object processMessageGroup(MessageGroup group)
MessageGroupProcessor
If a multiple messages are returned the return value must be a Collection<Message>.
processMessageGroup
in interface MessageGroupProcessor
group
- The message group.