org.springframework.integration.dsl

Class CorrelationHandlerSpec<S extends CorrelationHandlerSpec<S,H>,H extends AbstractCorrelatingMessageHandler>

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<T>

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<S,H>

Type Parameters:

S - the target CorrelationHandlerSpec implementation type.

H - the AbstractCorrelatingMessageHandler implementation type.

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,H>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

Direct Known Subclasses:

AggregatorSpec, ResequencerSpec

public abstract class CorrelationHandlerSpec<S extends CorrelationHandlerSpec<S,H>,H extends AbstractCorrelatingMessageHandler>
extends ConsumerEndpointSpec<S,H>

A MessageHandlerSpec for an AbstractCorrelatingMessageHandler.

Since:

5.0

Author:

Artem Bilan, Gary Russell

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

PARSER, target

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CorrelationHandlerSpec(H messageHandler)

Method Summary

Modifier and Type	Method and Description
S	correlationExpression(String correlationExpression) Configure the handler with an ExpressionEvaluatingCorrelationStrategy for the given expression.
S	correlationStrategy(CorrelationStrategy correlationStrategy)
S	correlationStrategy(Object target, String methodName) Configure the handler with an MethodInvokingCorrelationStrategy for the target object and method name.
S	discardChannel(MessageChannel discardChannel)
S	discardChannel(String discardChannelName)
S	expireGroupsUponTimeout(boolean expireGroupsUponTimeout) Expire (completely remove) a group if it is completed due to timeout.
S	forceReleaseAdvice(Advice... advice) Configure a list of Advice objects to be applied to the forceComplete() operation.
S	groupTimeout(java.util.function.Function<MessageGroup,Long> groupTimeoutFunction) Configure the handler with a function that will be invoked to resolve the group timeout, based on the message group.
S	groupTimeout(long groupTimeout) Configure the handler with a group timeout expression that evaluates to this constant value.
S	groupTimeoutExpression(String groupTimeoutExpression)
S	lockRegistry(LockRegistry lockRegistry) Used to obtain a Lock based on the groupId for concurrent operations on the MessageGroup.
S	messageStore(MessageGroupStore messageStore)
S	minimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups)
S	popSequence(boolean popSequence) Perform a MessageBuilder.popSequenceDetails() for output message or not.
S	processor(Object target) Configure the handler with MethodInvokingCorrelationStrategy and MethodInvokingReleaseStrategy using the target object which should have methods annotated appropriately for each function.
S	releaseExpression(String releaseExpression) Configure the handler with an ExpressionEvaluatingReleaseStrategy for the given expression.
S	releaseStrategy(Object target, String methodName) Configure the handler with an MethodInvokingReleaseStrategy for the target object and method name.
S	releaseStrategy(ReleaseStrategy releaseStrategy)
S	sendPartialResultOnExpiry(boolean sendPartialResultOnExpiry)
S	taskScheduler(TaskScheduler taskScheduler) Configure a TaskScheduler for scheduling tasks, for example in the Polling Consumer.

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, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

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

Constructor Detail

CorrelationHandlerSpec

protected CorrelationHandlerSpec(H messageHandler)

Method Detail

messageStore

public S messageStore(MessageGroupStore messageStore)

Parameters:

messageStore - the message group store.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setMessageStore(MessageGroupStore)

sendPartialResultOnExpiry

public S sendPartialResultOnExpiry(boolean sendPartialResultOnExpiry)

Parameters:

sendPartialResultOnExpiry - the sendPartialResultOnExpiry.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setSendPartialResultOnExpiry(boolean)

minimumTimeoutForEmptyGroups

public S minimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups)

Parameters:

minimumTimeoutForEmptyGroups - the minimumTimeoutForEmptyGroups

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setMinimumTimeoutForEmptyGroups(long)

groupTimeout

public S groupTimeout(long groupTimeout)

Configure the handler with a group timeout expression that evaluates to this constant value.

Parameters:

groupTimeout - the group timeout in milliseconds.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression), ValueExpression

groupTimeoutExpression

public S groupTimeoutExpression(String groupTimeoutExpression)

Parameters:

groupTimeoutExpression - the group timeout expression string.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression)

groupTimeout

public S groupTimeout(java.util.function.Function<MessageGroup,Long> groupTimeoutFunction)

Configure the handler with a function that will be invoked to resolve the group timeout, based on the message group. Usually used with a JDK8 lambda:

.groupTimeout(g -> g.size() * 2000L).

Parameters:

groupTimeoutFunction - a function invoked to resolve the group timeout in milliseconds.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression)

taskScheduler

public S taskScheduler(TaskScheduler taskScheduler)

Description copied from class: ConsumerEndpointSpec

Configure a TaskScheduler for scheduling tasks, for example in the Polling Consumer. By default the global ThreadPoolTaskScheduler bean is used. This configuration is useful when there are requirements to dedicate particular threads for polling task, for example.

Overrides:

taskScheduler in class ConsumerEndpointSpec<S extends CorrelationHandlerSpec<S,H>,H extends AbstractCorrelatingMessageHandler>

Parameters:

taskScheduler - the task scheduler.

Returns:

the handler spec.

See Also:

IntegrationObjectSupport.setTaskScheduler(TaskScheduler)

discardChannel

public S discardChannel(MessageChannel discardChannel)

Parameters:

discardChannel - the discard channel.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setDiscardChannel(MessageChannel)

discardChannel

public S discardChannel(String discardChannelName)

Parameters:

discardChannelName - the discard channel.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setDiscardChannelName(String)

processor

public S processor(Object target)

Configure the handler with MethodInvokingCorrelationStrategy and MethodInvokingReleaseStrategy using the target object which should have methods annotated appropriately for each function.

Parameters:

target - the target object

Returns:

the handler spec.

See Also:

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

correlationExpression

public S correlationExpression(String correlationExpression)

Configure the handler with an ExpressionEvaluatingCorrelationStrategy for the given expression.

Parameters:

correlationExpression - the correlation expression.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)

correlationStrategy

public S correlationStrategy(Object target,
                             String methodName)

Configure the handler with an MethodInvokingCorrelationStrategy for the target object and method name.

Parameters:

target - the target object.

methodName - the method name.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)

correlationStrategy

public S correlationStrategy(CorrelationStrategy correlationStrategy)

Parameters:

correlationStrategy - the correlation strategy.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)

releaseExpression

public S releaseExpression(String releaseExpression)

Configure the handler with an ExpressionEvaluatingReleaseStrategy for the given expression.

Parameters:

releaseExpression - the correlation expression.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)

releaseStrategy

public S releaseStrategy(Object target,
                         String methodName)

Configure the handler with an MethodInvokingReleaseStrategy for the target object and method name.

Parameters:

target - the target object.

methodName - the method name.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)

releaseStrategy

public S releaseStrategy(ReleaseStrategy releaseStrategy)

Parameters:

releaseStrategy - the release strategy.

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)

expireGroupsUponTimeout

public S expireGroupsUponTimeout(boolean expireGroupsUponTimeout)

Expire (completely remove) a group if it is completed due to timeout. Default true for aggregator and false for resequencer.

Parameters:

expireGroupsUponTimeout - the expireGroupsUponTimeout to set

Returns:

the handler spec.

See Also:

AbstractCorrelatingMessageHandler.setExpireGroupsUponTimeout(boolean)

forceReleaseAdvice

public S forceReleaseAdvice(Advice... advice)

Configure a list of Advice objects to be applied to the forceComplete() operation.

Parameters:

advice - the advice chain.

Returns:

the endpoint spec.

lockRegistry

public S lockRegistry(LockRegistry lockRegistry)

Used to obtain a Lock based on the groupId for concurrent operations on the MessageGroup. By default, an internal DefaultLockRegistry is used. Use of a distributed LockRegistry, such as the RedisLockRegistry, ensures only one instance of the aggregator will operate on a group concurrently.

Parameters:

lockRegistry - the LockRegistry to use.

Returns:

the endpoint spec.

popSequence

public S popSequence(boolean popSequence)

Perform a MessageBuilder.popSequenceDetails() for output message or not.

Parameters:

popSequence - the boolean flag to use.

Returns:

the endpoint spec.

Since:

5.1

See Also:

AbstractCorrelatingMessageHandler.setPopSequence(boolean)