public abstract class ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>,H extends org.springframework.messaging.MessageHandler> extends EndpointSpec<S,org.springframework.integration.config.ConsumerEndpointFactoryBean,H>
EndpointSpec for consumer endpoints.id, logger, PARSER, target| Modifier | Constructor and Description |
|---|---|
protected |
ConsumerEndpointSpec(H messageHandler) |
| 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 |
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) |
doGet, id, poller, poller_this, get, getIdprotected ConsumerEndpointSpec(H messageHandler)
public S phase(int phase)
phase in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,org.springframework.integration.config.ConsumerEndpointFactoryBean,H extends org.springframework.messaging.MessageHandler>phase - the phase.SmartLifecyclepublic S autoStartup(boolean autoStartup)
autoStartup in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,org.springframework.integration.config.ConsumerEndpointFactoryBean,H extends org.springframework.messaging.MessageHandler>autoStartup - the autoStartup.SmartLifecyclepublic S poller(org.springframework.integration.scheduling.PollerMetadata pollerMetadata)
poller in class EndpointSpec<S extends ConsumerEndpointSpec<S,H>,org.springframework.integration.config.ConsumerEndpointFactoryBean,H extends org.springframework.messaging.MessageHandler>pollerMetadata - the pollerMetadataAbstractPollingEndpointpublic S advice(org.aopalliance.aop.Advice... advice)
Advice objects to be applied, in nested order, to the endpoint's handler.
The advice objects are applied only to the handler and not the downstream flow.advice - the advice chain.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)