org.springframework.integration.aggregator

Class SequenceSizeReleaseStrategy

java.lang.Object

org.springframework.integration.aggregator.SequenceSizeReleaseStrategy

All Implemented Interfaces:

ReleaseStrategy

public class SequenceSizeReleaseStrategy
extends Object
implements ReleaseStrategy

An implementation of ReleaseStrategy that simply compares the current size of the message list to the expected 'sequenceSize'.

Author:

Mark Fisher, Marius Bogoevici, Dave Syer, Iwein Fuld, Oleg Zhurakousky

Constructor Summary

Constructors

Constructor and Description
SequenceSizeReleaseStrategy()
SequenceSizeReleaseStrategy(boolean releasePartialSequences)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canRelease(MessageGroup messageGroup)
void	setReleasePartialSequences(boolean releasePartialSequences) Flag that determines if partial sequences are allowed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SequenceSizeReleaseStrategy

public SequenceSizeReleaseStrategy()

SequenceSizeReleaseStrategy

public SequenceSizeReleaseStrategy(boolean releasePartialSequences)

Method Detail

setReleasePartialSequences

public void setReleasePartialSequences(boolean releasePartialSequences)

Flag that determines if partial sequences are allowed. If true then as soon as enough messages arrive that can be ordered they will be released, provided they all have sequence numbers greater than those already released.

Parameters:

releasePartialSequences - true when partial sequences should be released.

canRelease

public boolean canRelease(MessageGroup messageGroup)

Specified by:

canRelease in interface ReleaseStrategy