public class AmqpInboundChannelAdapterSpec extends AmqpBaseInboundChannelAdapterSpec<AmqpInboundChannelAdapterSpec>
MessageProducerSpec for AmqpInboundChannelAdapters.id, logger, PARSER, targetheaderMapper, mappedRequestHeaders, messageConverterautoStartup, doGet, errorChannel, id, outputChannel, phase_this, get, getIdpublic AmqpInboundChannelAdapterSpec acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
acknowledgeMode - the acknowledgeMode.AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)public AmqpInboundChannelAdapterSpec addQueueNames(java.lang.String... queueName)
queueName - a vararg list of queue names to add.SimpleMessageListenerContainer.addQueueNames(String...)public AmqpInboundChannelAdapterSpec addQueues(org.springframework.amqp.core.Queue... queues)
queues - a vararg list of queues to add.SimpleMessageListenerContainer.addQueueNames(String...)public AmqpInboundChannelAdapterSpec errorHandler(org.springframework.util.ErrorHandler errorHandler)
errorHandler - the errorHandler.AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)public AmqpInboundChannelAdapterSpec channelTransacted(boolean transactional)
transactional - true for transactional channels.RabbitAccessor.setChannelTransacted(boolean)public AmqpInboundChannelAdapterSpec adviceChain(org.aopalliance.aop.Advice... adviceChain)
adviceChain - the adviceChain.SimpleMessageListenerContainer.setAdviceChain(Advice[])public AmqpInboundChannelAdapterSpec recoveryInterval(long recoveryInterval)
recoveryInterval - the recoveryIntervalSimpleMessageListenerContainer.setRecoveryInterval(long)public AmqpInboundChannelAdapterSpec concurrentConsumers(int concurrentConsumers)
concurrentConsumers - the concurrentConsumersSimpleMessageListenerContainer.setConcurrentConsumers(int)public AmqpInboundChannelAdapterSpec maxConcurrentConsumers(int maxConcurrentConsumers)
maxConcurrentConsumers - the maxConcurrentConsumers.SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)public AmqpInboundChannelAdapterSpec exclusive(boolean exclusive)
exclusive - true for exclusive.SimpleMessageListenerContainer.setExclusive(boolean)public AmqpInboundChannelAdapterSpec startConsumerMinInterval(long startConsumerMinInterval)
startConsumerMinInterval - the startConsumerMinIntervalSimpleMessageListenerContainer.setStartConsumerMinInterval(long)public AmqpInboundChannelAdapterSpec stopConsumerMinInterval(long stopConsumerMinInterval)
stopConsumerMinInterval - the stopConsumerMinInterval.SimpleMessageListenerContainer.setStopConsumerMinInterval(long)public AmqpInboundChannelAdapterSpec consecutiveActiveTrigger(int consecutiveActiveTrigger)
consecutiveActiveTrigger - the consecutiveActiveTrigger.SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)public AmqpInboundChannelAdapterSpec consecutiveIdleTrigger(int consecutiveIdleTrigger)
consecutiveIdleTrigger - the consecutiveIdleTrigger.SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)public AmqpInboundChannelAdapterSpec receiveTimeout(long receiveTimeout)
receiveTimeout - the receiveTimeoutSimpleMessageListenerContainer.setReceiveTimeout(long)public AmqpInboundChannelAdapterSpec shutdownTimeout(long shutdownTimeout)
shutdownTimeout - the shutdownTimeout.SimpleMessageListenerContainer.setShutdownTimeout(long)public AmqpInboundChannelAdapterSpec taskExecutor(java.util.concurrent.Executor taskExecutor)
Executor used to invoke the message listener.taskExecutor - the taskExecutor.public AmqpInboundChannelAdapterSpec prefetchCount(int prefetchCount)
prefetchCount - the prefetchCount.SimpleMessageListenerContainer.setPrefetchCount(int)public AmqpInboundChannelAdapterSpec txSize(int txSize)
txSize - the txSize.SimpleMessageListenerContainer.setTxSize(int)public AmqpInboundChannelAdapterSpec transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
PlatformTransactionManager; used to synchronize the rabbit transaction
with some other transaction(s).transactionManager - the transactionManager.public AmqpInboundChannelAdapterSpec defaultRequeueRejected(boolean defaultRequeueRejected)
defaultRequeueRejected - the defaultRequeueRejected.SimpleMessageListenerContainer.setDefaultRequeueRejected(boolean)