public class AmqpInboundChannelAdapterSpec extends MessageProducerSpec<AmqpInboundChannelAdapterSpec,org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter>
id, logger, PARSER, target
Constructor and Description |
---|
AmqpInboundChannelAdapterSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) |
autoStartup, doGet, errorChannel, id, outputChannel, phase
_this, get, getId
public AmqpInboundChannelAdapterSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
public AmqpInboundChannelAdapterSpec acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
public AmqpInboundChannelAdapterSpec addQueueNames(java.lang.String... queueName)
public AmqpInboundChannelAdapterSpec addQueues(org.springframework.amqp.core.Queue... queues)
public AmqpInboundChannelAdapterSpec errorHandler(org.springframework.util.ErrorHandler errorHandler)
public AmqpInboundChannelAdapterSpec channelTransacted(boolean transactional)
public AmqpInboundChannelAdapterSpec adviceChain(org.aopalliance.aop.Advice... adviceChain)
public AmqpInboundChannelAdapterSpec recoveryInterval(long recoveryInterval)
public AmqpInboundChannelAdapterSpec concurrentConsumers(int concurrentConsumers)
public AmqpInboundChannelAdapterSpec maxConcurrentConsumers(int maxConcurrentConsumers)
public AmqpInboundChannelAdapterSpec exclusive(boolean exclusive)
public AmqpInboundChannelAdapterSpec startConsumerMinInterval(long startConsumerMinInterval)
public AmqpInboundChannelAdapterSpec stopConsumerMinInterval(long stopConsumerMinInterval)
public AmqpInboundChannelAdapterSpec consecutiveActiveTrigger(int consecutiveActiveTrigger)
public AmqpInboundChannelAdapterSpec consecutiveIdleTrigger(int consecutiveIdleTrigger)
public AmqpInboundChannelAdapterSpec receiveTimeout(long receiveTimeout)
public AmqpInboundChannelAdapterSpec shutdownTimeout(long shutdownTimeout)
public AmqpInboundChannelAdapterSpec taskExecutor(java.util.concurrent.Executor taskExecutor)
public AmqpInboundChannelAdapterSpec prefetchCount(int prefetchCount)
public AmqpInboundChannelAdapterSpec txSize(int txSize)
public AmqpInboundChannelAdapterSpec transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public AmqpInboundChannelAdapterSpec defaultRequeueRejected(boolean defaultRequeueRejected)
public AmqpInboundChannelAdapterSpec messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
public AmqpInboundChannelAdapterSpec headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper)
public AmqpInboundChannelAdapterSpec mappedRequestHeaders(java.lang.String... headers)