Package | Description |
---|---|
org.springframework.integration.aggregator |
Provides classes related to message aggregation.
|
org.springframework.integration.config |
Base package for configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
ExpressionEvaluatingReleaseStrategy
A
ReleaseStrategy that evaluates an expression. |
class |
MessageCountReleaseStrategy
|
class |
MethodInvokingReleaseStrategy
A
ReleaseStrategy that invokes a method on a plain old Java object. |
class |
SequenceSizeReleaseStrategy
An implementation of
ReleaseStrategy that simply compares the current size of the message list to the
expected 'sequenceSize'. |
class |
TimeoutCountSequenceSizeReleaseStrategy
A
ReleaseStrategy that releases all messages if any of the following is true:
The sequence is complete (if there is one).
There are more messages than a threshold set by the user.
The time elapsed since the earliest message, according to their timestamps, exceeds a timeout set by the user.
|
Modifier and Type | Method and Description |
---|---|
void |
CorrelatingMessageBarrier.setReleaseStrategy(ReleaseStrategy releaseStrategy)
Set the ReleaseStrategy that should be used when deciding if a group in this barrier may be released.
|
void |
AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy releaseStrategy) |
Constructor and Description |
---|
AbstractCorrelatingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store,
CorrelationStrategy correlationStrategy,
ReleaseStrategy releaseStrategy) |
AggregatingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store,
CorrelationStrategy correlationStrategy,
ReleaseStrategy releaseStrategy) |
ResequencingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store,
CorrelationStrategy correlationStrategy,
ReleaseStrategy releaseStrategy) |
Modifier and Type | Method and Description |
---|---|
ReleaseStrategy |
ReleaseStrategyFactoryBean.getObject() |
Copyright © 2017. All rights reserved.