public abstract class CorrelationHandlerSpec<S extends CorrelationHandlerSpec<S,H>,H extends org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler> extends MessageHandlerSpec<S,H>
Modifier and Type | Field and Description |
---|---|
protected org.springframework.integration.store.MessageGroupStore |
messageStore |
protected boolean |
sendPartialResultOnExpiry |
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
protected H |
configure(H handler) |
S |
correlationExpression(java.lang.String correlationExpression) |
S |
correlationStrategy(org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy) |
S |
correlationStrategy(java.lang.Object target,
java.lang.String methodName) |
S |
discardChannel(org.springframework.messaging.MessageChannel discardChannel) |
S |
discardChannel(java.lang.String discardChannelName) |
S |
groupTimeout(Function<org.springframework.integration.store.MessageGroup,java.lang.Long> groupTimeoutFunction) |
S |
groupTimeout(long groupTimeout) |
S |
groupTimeoutExpression(java.lang.String groupTimeoutExpression) |
S |
messageStore(org.springframework.integration.store.MessageGroupStore messageStore) |
S |
minimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups) |
S |
processor(java.lang.Object target,
java.lang.String methodName) |
S |
releaseExpression(java.lang.String releaseExpression) |
S |
releaseStrategy(java.lang.Object target,
java.lang.String methodName) |
S |
releaseStrategy(org.springframework.integration.aggregator.ReleaseStrategy releaseStrategy) |
S |
sendPartialResultOnExpiry(boolean sendPartialResultOnExpiry) |
S |
taskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler) |
protected org.springframework.integration.store.MessageGroupStore messageStore
protected boolean sendPartialResultOnExpiry
public S messageStore(org.springframework.integration.store.MessageGroupStore messageStore)
public S sendPartialResultOnExpiry(boolean sendPartialResultOnExpiry)
public S minimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups)
public S groupTimeout(long groupTimeout)
public S groupTimeoutExpression(java.lang.String groupTimeoutExpression)
public S groupTimeout(Function<org.springframework.integration.store.MessageGroup,java.lang.Long> groupTimeoutFunction)
public S taskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler)
public S discardChannel(org.springframework.messaging.MessageChannel discardChannel)
public S discardChannel(java.lang.String discardChannelName)
public S processor(java.lang.Object target, java.lang.String methodName)
public S correlationExpression(java.lang.String correlationExpression)
public S correlationStrategy(java.lang.Object target, java.lang.String methodName)
public S correlationStrategy(org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy)
public S releaseExpression(java.lang.String releaseExpression)
public S releaseStrategy(java.lang.Object target, java.lang.String methodName)
public S releaseStrategy(org.springframework.integration.aggregator.ReleaseStrategy releaseStrategy)