org.springframework.integration.dsl

Class AggregatorSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,reactor.util.function.Tuple2<F,H>>

org.springframework.integration.dsl.EndpointSpec<S,ConsumerEndpointFactoryBean,H>

org.springframework.integration.dsl.ConsumerEndpointSpec<S,H>

org.springframework.integration.dsl.CorrelationHandlerSpec<AggregatorSpec,AggregatingMessageHandler>

org.springframework.integration.dsl.AggregatorSpec

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,AggregatingMessageHandler>>, org.springframework.beans.factory.InitializingBean, ComponentsRegistration

public class AggregatorSpec
extends CorrelationHandlerSpec<AggregatorSpec,AggregatingMessageHandler>

A CorrelationHandlerSpec for an AggregatingMessageHandler.

Since:

5.0

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.dsl.ConsumerEndpointSpec

adviceChain

Fields inherited from class org.springframework.integration.dsl.EndpointSpec

componentsToRegister, endpointFactoryBean, handler

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Method Summary

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(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.

Methods inherited from class org.springframework.integration.dsl.CorrelationHandlerSpec

correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, expireGroupsUponTimeout, forceReleaseAdvice, groupTimeout, groupTimeout, groupTimeoutExpression, lockRegistry, messageStore, minimumTimeoutForEmptyGroups, releaseExpression, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskScheduler

Methods inherited from class org.springframework.integration.dsl.ConsumerEndpointSpec

advice, async, autoStartup, doGet, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, transactional, transactional, transactional, transactional, transactional

Methods inherited from class org.springframework.integration.dsl.EndpointSpec

assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

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

Method Detail

processor

public 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. Also set the output processor.

Overrides:

processor in class CorrelationHandlerSpec<AggregatorSpec,AggregatingMessageHandler>

Parameters:

target - the target object.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy), AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)

processor

public 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. Also set the output processor.

Parameters:

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).

Returns:

the handler spec.

outputExpression

public AggregatorSpec outputExpression(java.lang.String expression)

An expression to determine the output message from the released group. Defaults to a message with a payload that is a collection of payloads from the input messages.

Parameters:

expression - the expression.

Returns:

the aggregator spec.

outputProcessor

public AggregatorSpec outputProcessor(MessageGroupProcessor outputProcessor)

A processor to determine the output message from the released group. Defaults to a message with a payload that is a collection of payloads from the input messages.

Parameters:

outputProcessor - the processor.

Returns:

the aggregator spec.

expireGroupsUponCompletion

public AggregatorSpec expireGroupsUponCompletion(boolean expireGroupsUponCompletion)

Parameters:

expireGroupsUponCompletion - the expireGroupsUponCompletion.

Returns:

the aggregator spec.

See Also:

AggregatingMessageHandler.setExpireGroupsUponCompletion(boolean)