public class AmqpInboundChannelAdapterSpec extends AmqpBaseInboundChannelAdapterSpec<AmqpInboundChannelAdapterSpec> implements ComponentsRegistration
logger, PARSER, targetheaderMapper, mappedRequestHeaders, messageConverterautoStartup, errorChannel, errorChannel, id, outputChannel, outputChannel, phase_this, doGet, get, getId, getObject, getObjectType, isSingletonpublic AmqpInboundChannelAdapterSpec acknowledgeMode(AcknowledgeMode acknowledgeMode)
acknowledgeMode - the acknowledgeMode.AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)public AmqpInboundChannelAdapterSpec addQueueNames(String... queueName)
queueName - a vararg list of queue names to add.SimpleMessageListenerContainer.addQueueNames(String...)public AmqpInboundChannelAdapterSpec addQueues(Queue... queues)
queues - a vararg list of queues to add.SimpleMessageListenerContainer.addQueueNames(String...)public AmqpInboundChannelAdapterSpec errorHandler(ErrorHandler errorHandler)
errorHandler - the errorHandler.AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)public AmqpInboundChannelAdapterSpec channelTransacted(boolean transactional)
transactional - true for transactional channels.RabbitAccessor.setChannelTransacted(boolean)public AmqpInboundChannelAdapterSpec adviceChain(Advice... adviceChain)
adviceChain - the adviceChain.AbstractMessageListenerContainer.setAdviceChain(Advice[])public AmqpInboundChannelAdapterSpec recoveryInterval(long recoveryInterval)
recoveryInterval - the recoveryIntervalAbstractMessageListenerContainer.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.AbstractMessageListenerContainer.setShutdownTimeout(long)public AmqpInboundChannelAdapterSpec taskExecutor(Executor taskExecutor)
Executor used to invoke the message listener.taskExecutor - the taskExecutor.public AmqpInboundChannelAdapterSpec prefetchCount(int prefetchCount)
prefetchCount - the prefetchCount.AbstractMessageListenerContainer.setPrefetchCount(int)public AmqpInboundChannelAdapterSpec txSize(int txSize)
txSize - the txSize.SimpleMessageListenerContainer.setTxSize(int)public AmqpInboundChannelAdapterSpec transactionManager(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.AbstractMessageListenerContainer.setDefaultRequeueRejected(boolean)public Collection<Object> getComponentsToRegister()
getComponentsToRegister in interface ComponentsRegistration