S - the target ConsumerEndpointSpec implementation type.H - the target MessageHandler implementation type.public abstract class ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>,H extends MessageHandler> extends EndpointSpec<S,ConsumerEndpointFactoryBean,H>
EndpointSpec for consumer endpoints.| Modifier and Type | Field and Description |
|---|---|
protected List<Advice> |
adviceChain |
componentToRegister, endpointFactoryBean, handlerlogger, PARSER, target| Modifier | Constructor and Description |
|---|---|
protected |
ConsumerEndpointSpec(H messageHandler) |
| Modifier and Type | Method and Description |
|---|---|
S |
advice(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(PollerMetadata pollerMetadata) |
S |
requiresReply(boolean requiresReply) |
S |
sendTimeout(long sendTimeout) |
S |
transactional()
Specify a
TransactionInterceptor Advice with default
PlatformTransactionManager and DefaultTransactionAttribute for the
MessageHandler. |
S |
transactional(boolean handleMessageAdvice)
Specify a
TransactionInterceptor Advice with default
PlatformTransactionManager and DefaultTransactionAttribute for the
MessageHandler. |
S |
transactional(PlatformTransactionManager transactionManager)
Specify a
TransactionInterceptor Advice with the provided
PlatformTransactionManager and default DefaultTransactionAttribute
for the MessageHandler. |
S |
transactional(PlatformTransactionManager transactionManager,
boolean handleMessageAdvice)
Specify a
TransactionInterceptor Advice with the provided
PlatformTransactionManager and default DefaultTransactionAttribute
for the MessageHandler. |
S |
transactional(TransactionInterceptor transactionInterceptor)
|
assertHandler, doGet, getComponentsToRegister, id, poller, poller_this, get, getId, getObject, getObjectType, isSingletonprotected ConsumerEndpointSpec(H messageHandler)
public S phase(int phase)
phase in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,ConsumerEndpointFactoryBean,H extends MessageHandler>phase - the phase.SmartLifecyclepublic S autoStartup(boolean autoStartup)
autoStartup in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,ConsumerEndpointFactoryBean,H extends MessageHandler>autoStartup - the autoStartup.SmartLifecyclepublic S poller(PollerMetadata pollerMetadata)
poller in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,ConsumerEndpointFactoryBean,H extends MessageHandler>pollerMetadata - the pollerMetadataAbstractPollingEndpointpublic S advice(Advice... advice)
Advice objects to be applied, in nested order, to the
endpoint's handler. The advice objects are applied only to the handler.advice - the advice chain.public S transactional(PlatformTransactionManager transactionManager)
TransactionInterceptor Advice with the provided
PlatformTransactionManager and default DefaultTransactionAttribute
for the MessageHandler.transactionManager - the PlatformTransactionManager to use.public S transactional(PlatformTransactionManager transactionManager, boolean handleMessageAdvice)
TransactionInterceptor Advice with the provided
PlatformTransactionManager and default DefaultTransactionAttribute
for the MessageHandler.transactionManager - the PlatformTransactionManager to use.handleMessageAdvice - the flag to indicate the target Advice type:
false - regular TransactionInterceptor; true -
TransactionHandleMessageAdvice
extension.public S transactional(TransactionInterceptor transactionInterceptor)
transactionInterceptor - the TransactionInterceptor to use.TransactionInterceptorBuilderpublic S transactional()
TransactionInterceptor Advice with default
PlatformTransactionManager and DefaultTransactionAttribute for the
MessageHandler.public S transactional(boolean handleMessageAdvice)
TransactionInterceptor Advice with default
PlatformTransactionManager and DefaultTransactionAttribute for the
MessageHandler.handleMessageAdvice - the flag to indicate the target Advice type:
false - regular TransactionInterceptor; true -
TransactionHandleMessageAdvice
extension.public S requiresReply(boolean requiresReply)
requiresReply - the requiresReply.AbstractReplyProducingMessageHandler.setRequiresReply(boolean)public S sendTimeout(long sendTimeout)
sendTimeout - the send timeout.AbstractMessageProducingHandler.setSendTimeout(long)public S order(int order)
order - the order.AbstractMessageHandler.setOrder(int)public S async(boolean async)
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.async - true to allow.AbstractMessageProducingHandler.setAsync(boolean)