Class AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup
java.lang.Object
org.springframework.integration.store.SimpleMessageGroup
org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup
- All Implemented Interfaces:
MessageGroup
- Enclosing class:
AbstractCorrelatingMessageHandler
protected static class AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup
extends SimpleMessageGroup
- Since:
- 2.0
- Author:
- Iwein Fuld, Dave Syer, Oleg Zhurakousky, Gary Russell, Artem Bilan, David Liu, Enrique Rodriguez, Meherzad Lahewala, Jayadev Sirimamilla, Ngoc Nhan
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.springframework.integration.store.SimpleMessageGroup
add, clear, complete, containsSequence, getCondition, getGroupId, getLastModified, getLastReleasedMessageSequenceNumber, getMessages, getOne, getSequenceSize, getTimestamp, isComplete, remove, setCondition, setLastModified, setLastReleasedMessageSequenceNumber, size, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.springframework.integration.store.MessageGroup
streamMessages
-
Constructor Details
-
SequenceAwareMessageGroup
-
-
Method Details
-
canAdd
This method determines whether messages have been added to this group that supersede the given message based on its sequence id. This can be helpful to avoid ending up with sequences larger than their required sequence size or sequences that are missing certain sequence numbers.- Specified by:
canAdd
in interfaceMessageGroup
- Overrides:
canAdd
in classSimpleMessageGroup
- Parameters:
message
- The message.- Returns:
- true if the message can be added.
-