public class AggregatorSpec extends CorrelationHandlerSpec<AggregatorSpec,org.springframework.integration.aggregator.AggregatingMessageHandler>
CorrelationHandlerSpec for an AggregatingMessageHandler.componentToRegisterid, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
AggregatorSpec |
expireGroupsUponCompletion(boolean expireGroupsUponCompletion) |
AggregatorSpec |
outputExpression(java.lang.String expression)
An expression to determine the output message from the released group.
|
AggregatorSpec |
outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)
A processor to determine the output message from the released group.
|
AggregatorSpec |
processor(java.lang.Object target)
Configure the handler with
MethodInvokingCorrelationStrategy
and MethodInvokingReleaseStrategy using the target
object which should have methods annotated appropriately for each function. |
AggregatorSpec |
processor(java.lang.Object target,
java.lang.String methodName)
Configure the handler with
MethodInvokingCorrelationStrategy
and MethodInvokingReleaseStrategy using the target
object which should have methods annotated appropriately for each function. |
correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, expireGroupsUponTimeout, forceReleaseAdvice, groupTimeout, groupTimeout, groupTimeoutExpression, lockRegistry, messageStore, minimumTimeoutForEmptyGroups, releaseExpression, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskScheduleradvice, autoStartup, order, phase, poller, requiresReply, sendTimeout, transactional, transactional, transactional, transactional, transactionalgetComponentsToRegister, id, poller, poller_this, doGet, get, getId, getObject, getObjectType, isSingletonpublic AggregatorSpec processor(java.lang.Object target)
MethodInvokingCorrelationStrategy
and MethodInvokingReleaseStrategy using the target
object which should have methods annotated appropriately for each function.
Also set the output processor.processor in class CorrelationHandlerSpec<AggregatorSpec,org.springframework.integration.aggregator.AggregatingMessageHandler>target - the target object.AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy),
AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)public AggregatorSpec processor(java.lang.Object target, java.lang.String methodName)
MethodInvokingCorrelationStrategy
and MethodInvokingReleaseStrategy using the target
object which should have methods annotated appropriately for each function.
Also set the output processor.target - the target object.methodName - The method name for the output processor (or 'null' in which case, the
target object must have an Aggregator
annotation).public AggregatorSpec outputExpression(java.lang.String expression)
expression - the expression.public AggregatorSpec outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)
outputProcessor - the processor.public AggregatorSpec expireGroupsUponCompletion(boolean expireGroupsUponCompletion)
expireGroupsUponCompletion - the expireGroupsUponCompletion.AggregatingMessageHandler.setExpireGroupsUponCompletion(boolean)