protected static class AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup extends SimpleMessageGroup
Constructor and Description |
---|
SequenceAwareMessageGroup(MessageGroup messageGroup) |
Modifier and Type | Method and Description |
---|---|
boolean |
canAdd(Message<?> message)
This method determines whether messages have been added to this group that
supersede the given message based on its sequence id.
|
add, clear, complete, containsSequence, getGroupId, getLastModified, getLastReleasedMessageSequenceNumber, getMessages, getOne, getSequenceSize, getTimestamp, isComplete, remove, setLastModified, setLastReleasedMessageSequenceNumber, size, toString
public SequenceAwareMessageGroup(MessageGroup messageGroup)
public boolean canAdd(Message<?> message)
canAdd
in interface MessageGroup
canAdd
in class SimpleMessageGroup
message
- The message.