Package org.springframework.integration.aggregator

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

Constructor Summary

Constructors

Constructor	Description
SequenceAwareMessageGroup(MessageGroup messageGroup)

Method Summary

Modifier and Type	Method	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.

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

public SequenceAwareMessageGroup(MessageGroup messageGroup)

Method Details

canAdd

public 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. 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 interface MessageGroup

Overrides:

canAdd in class SimpleMessageGroup

Parameters:

message - The message.

Returns:

true if the message can be added.