org.springframework.integration.dsl.core

Class ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>,H extends org.springframework.messaging.MessageHandler>

java.lang.Object

org.springframework.integration.dsl.core.IntegrationComponentSpec<S,Tuple2<F,H>>

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

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

Type Parameters:

S - the target ConsumerEndpointSpec implementation type.

H - the target MessageHandler implementation type.

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<Tuple2<org.springframework.integration.config.ConsumerEndpointFactoryBean,H>>, ComponentsRegistration

Direct Known Subclasses:

BarrierSpec, CorrelationHandlerSpec, DelayerEndpointSpec, FilterEndpointSpec, GatewayEndpointSpec, GenericEndpointSpec, ScatterGatherSpec, SplitterEndpointSpec

public abstract class ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>,H extends org.springframework.messaging.MessageHandler>
extends EndpointSpec<S,org.springframework.integration.config.ConsumerEndpointFactoryBean,H>

A EndpointSpec for consumer endpoints.

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<org.aopalliance.aop.Advice>	adviceChain

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

componentToRegister, endpointFactoryBean, handler

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

logger, PARSER, target

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ConsumerEndpointSpec(H messageHandler)

Method Summary

Modifier and Type	Method and Description
S	advice(org.aopalliance.aop.Advice... advice) Configure a list of Advice objects to be applied, in nested order, to the endpoint's handler.
S	async(boolean async) Allow async replies.
S	autoStartup(boolean autoStartup)
S	order(int order)
S	phase(int phase)
S	poller(org.springframework.integration.scheduling.PollerMetadata pollerMetadata)
S	requiresReply(boolean requiresReply)
S	sendTimeout(long sendTimeout)
S	transactional() Specify a TransactionInterceptor Advice with default PlatformTransactionManager and DefaultTransactionAttribute for the pollingTask.
S	transactional(boolean handleMessageAdvice) Specify a TransactionInterceptor Advice with default PlatformTransactionManager and DefaultTransactionAttribute for the pollingTask.
S	transactional(org.springframework.transaction.PlatformTransactionManager transactionManager) Specify a TransactionInterceptor Advice with the provided PlatformTransactionManager and default DefaultTransactionAttribute for the pollingTask.
S	transactional(org.springframework.transaction.PlatformTransactionManager transactionManager, boolean handleMessageAdvice) Specify a TransactionInterceptor Advice with the provided PlatformTransactionManager and default DefaultTransactionAttribute for the pollingTask.
S	transactional(org.springframework.transaction.interceptor.TransactionInterceptor transactionInterceptor) Specify a TransactionInterceptor Advice for the pollingTask.

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

assertHandler, doGet, getComponentsToRegister, id, poller, poller

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

_this, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

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

Field Detail

adviceChain

protected final java.util.List<org.aopalliance.aop.Advice> adviceChain

Constructor Detail

ConsumerEndpointSpec

protected ConsumerEndpointSpec(H messageHandler)

Method Detail

phase

public S phase(int phase)

Specified by:

phase in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,org.springframework.integration.config.ConsumerEndpointFactoryBean,H extends org.springframework.messaging.MessageHandler>

Parameters:

phase - the phase.

Returns:

the endpoint spec.

See Also:

SmartLifecycle

autoStartup

public S autoStartup(boolean autoStartup)

Specified by:

autoStartup in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,org.springframework.integration.config.ConsumerEndpointFactoryBean,H extends org.springframework.messaging.MessageHandler>

Parameters:

autoStartup - the autoStartup.

Returns:

the endpoint spec

See Also:

SmartLifecycle

poller

public S poller(org.springframework.integration.scheduling.PollerMetadata pollerMetadata)

Specified by:

poller in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,org.springframework.integration.config.ConsumerEndpointFactoryBean,H extends org.springframework.messaging.MessageHandler>

Parameters:

pollerMetadata - the pollerMetadata

Returns:

the endpoint spec.

See Also:

AbstractPollingEndpoint

advice

public S advice(org.aopalliance.aop.Advice... advice)

Configure a list of Advice objects to be applied, in nested order, to the endpoint's handler. The advice objects are applied only to the handler.

Parameters:

advice - the advice chain.

Returns:

the endpoint spec.

transactional

public S transactional(org.springframework.transaction.PlatformTransactionManager transactionManager)

Specify a TransactionInterceptor Advice with the provided PlatformTransactionManager and default DefaultTransactionAttribute for the pollingTask.

Parameters:

transactionManager - the PlatformTransactionManager to use.

Returns:

the spec.

Since:

1.2

transactional

public S transactional(org.springframework.transaction.PlatformTransactionManager transactionManager,
                       boolean handleMessageAdvice)

Specify a TransactionInterceptor Advice with the provided PlatformTransactionManager and default DefaultTransactionAttribute for the pollingTask.

Parameters:

transactionManager - the PlatformTransactionManager to use.

handleMessageAdvice - the flag to indicate the target Advice type: false - regular TransactionInterceptor; true - TransactionHandleMessageAdvice extension.

Returns:

the spec.

Since:

1.2

transactional

public S transactional(org.springframework.transaction.interceptor.TransactionInterceptor transactionInterceptor)

Specify a TransactionInterceptor Advice for the pollingTask.

Parameters:

transactionInterceptor - the TransactionInterceptor to use.

Returns:

the spec.

Since:

1.2

See Also:

TransactionInterceptorBuilder

transactional

public S transactional()

Specify a TransactionInterceptor Advice with default PlatformTransactionManager and DefaultTransactionAttribute for the pollingTask.

Returns:

the spec.

Since:

1.2

transactional

public S transactional(boolean handleMessageAdvice)

Specify a TransactionInterceptor Advice with default PlatformTransactionManager and DefaultTransactionAttribute for the pollingTask.

Parameters:

handleMessageAdvice - the flag to indicate the target Advice type: false - regular TransactionInterceptor; true - TransactionHandleMessageAdvice extension.

Returns:

the spec.

Since:

1.2

requiresReply

public S requiresReply(boolean requiresReply)

Parameters:

requiresReply - the requiresReply.

Returns:

the endpoint spec.

See Also:

AbstractReplyProducingMessageHandler.setRequiresReply(boolean)

sendTimeout

public S sendTimeout(long sendTimeout)

Parameters:

sendTimeout - the send timeout.

Returns:

the endpoint spec.

See Also:

AbstractMessageProducingHandler.setSendTimeout(long)

order

public S order(int order)

Parameters:

order - the order.

Returns:

the endpoint spec.

See Also:

AbstractMessageHandler.setOrder(int)

async

public S async(boolean async)

Allow async replies. If the handler reply is a ListenableFuture send the output when it is satisfied rather than sending the future as the result. Only subclasses that support this feature should set it.

Parameters:

async - true to allow.

Returns:

the endpoint spec.

Since:

1.2

See Also:

AbstractMessageProducingHandler.setAsync(boolean)