org.springframework.integration.aggregator
Class DefaultResequencerStrategies

java.lang.Object
  org.springframework.integration.aggregator.DefaultResequencerStrategies

All Implemented Interfaces:

CompletionStrategy, CorrelationStrategy, MessageGroupProcessor

public class DefaultResequencerStrategies
extends java.lang.Object
implements CorrelationStrategy, CompletionStrategy, MessageGroupProcessor

Author:

Iwein Fuld

Constructor Summary

DefaultResequencerStrategies()

Method Summary

java.lang.Object	getCorrelationKey(Message<?> message)
boolean	isComplete(java.util.List<Message<?>> messages)
void	processAndSend(java.lang.Object correlationKey, java.util.Collection<Message<?>> all, MessageChannel outputChannel, BufferedMessagesCallback processedCallback)
void	setReleasePartialSequences(boolean releasePartialSequences)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultResequencerStrategies

public DefaultResequencerStrategies()

Method Detail

getCorrelationKey

public java.lang.Object getCorrelationKey(Message<?> message)

Specified by:

getCorrelationKey in interface CorrelationStrategy

isComplete

public boolean isComplete(java.util.List<Message<?>> messages)

Specified by:

isComplete in interface CompletionStrategy

processAndSend

public void processAndSend(java.lang.Object correlationKey,
                           java.util.Collection<Message<?>> all,
                           MessageChannel outputChannel,
                           BufferedMessagesCallback processedCallback)

Specified by:

processAndSend in interface MessageGroupProcessor

setReleasePartialSequences

public void setReleasePartialSequences(boolean releasePartialSequences)