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, getId
protected 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.SmartLifecycle
public 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.SmartLifecycle
public 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 pollerMetadataAbstractPollingEndpoint
public 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)