public class AmqpInboundGatewaySpec extends AmqpBaseInboundGatewaySpec<AmqpInboundGatewaySpec> implements ComponentsRegistration
AmqpBaseInboundGatewaySpec implementation for a AmqpInboundGateway.
Allows to provide SimpleMessageListenerContainer options.logger, PARSER, targetdefaultReplyTo, headerMapper, mappedReplyHeaders, mappedRequestHeaders, messageConverterautoStartup, errorChannel, errorChannel, id, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout_this, doGet, get, getId, getObject, getObjectType, isSingletonpublic AmqpInboundGatewaySpec acknowledgeMode(AcknowledgeMode acknowledgeMode)
acknowledgeMode - the acknowledgeMode.AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)public AmqpInboundGatewaySpec addQueueNames(String... queueName)
queueName - a vararg list of queue names to add.SimpleMessageListenerContainer.addQueueNames(String...)public AmqpInboundGatewaySpec addQueues(Queue... queues)
queues - a vararg list of queues to add.SimpleMessageListenerContainer.addQueueNames(String...)public AmqpInboundGatewaySpec errorHandler(ErrorHandler errorHandler)
errorHandler - the errorHandler.AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)public AmqpInboundGatewaySpec channelTransacted(boolean transactional)
transactional - true for transactional channels.RabbitAccessor.setChannelTransacted(boolean)public AmqpInboundGatewaySpec adviceChain(Advice... adviceChain)
adviceChain - the adviceChain.AbstractMessageListenerContainer.setAdviceChain(Advice[])public AmqpInboundGatewaySpec recoveryInterval(long recoveryInterval)
recoveryInterval - the recoveryIntervalAbstractMessageListenerContainer.setRecoveryInterval(long)public AmqpInboundGatewaySpec concurrentConsumers(int concurrentConsumers)
concurrentConsumers - the concurrentConsumersSimpleMessageListenerContainer.setConcurrentConsumers(int)public AmqpInboundGatewaySpec maxConcurrentConsumers(int maxConcurrentConsumers)
maxConcurrentConsumers - the maxConcurrentConsumers.SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)public AmqpInboundGatewaySpec exclusive(boolean exclusive)
exclusive - true for exclusive.SimpleMessageListenerContainer.setExclusive(boolean)public AmqpInboundGatewaySpec startConsumerMinInterval(long startConsumerMinInterval)
startConsumerMinInterval - the startConsumerMinIntervalSimpleMessageListenerContainer.setStartConsumerMinInterval(long)public AmqpInboundGatewaySpec stopConsumerMinInterval(long stopConsumerMinInterval)
stopConsumerMinInterval - the stopConsumerMinInterval.SimpleMessageListenerContainer.setStopConsumerMinInterval(long)public AmqpInboundGatewaySpec consecutiveActiveTrigger(int consecutiveActiveTrigger)
consecutiveActiveTrigger - the consecutiveActiveTrigger.SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)public AmqpInboundGatewaySpec consecutiveIdleTrigger(int consecutiveIdleTrigger)
consecutiveIdleTrigger - the consecutiveIdleTrigger.SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)public AmqpInboundGatewaySpec receiveTimeout(long receiveTimeout)
receiveTimeout - the receiveTimeoutSimpleMessageListenerContainer.setReceiveTimeout(long)public AmqpInboundGatewaySpec shutdownTimeout(long shutdownTimeout)
shutdownTimeout - the shutdownTimeout.AbstractMessageListenerContainer.setShutdownTimeout(long)public AmqpInboundGatewaySpec taskExecutor(Executor taskExecutor)
Executor used to invoke the message listener.taskExecutor - the taskExecutor.public AmqpInboundGatewaySpec prefetchCount(int prefetchCount)
prefetchCount - the prefetchCount.AbstractMessageListenerContainer.setPrefetchCount(int)public AmqpInboundGatewaySpec txSize(int txSize)
txSize - the txSize.SimpleMessageListenerContainer.setTxSize(int)public AmqpInboundGatewaySpec transactionManager(PlatformTransactionManager transactionManager)
PlatformTransactionManager; used to synchronize the rabbit transaction
with some other transaction(s).transactionManager - the transactionManager.public AmqpInboundGatewaySpec defaultRequeueRejected(boolean defaultRequeueRejected)
defaultRequeueRejected - the defaultRequeueRejected.AbstractMessageListenerContainer.setDefaultRequeueRejected(boolean)public Collection<Object> getComponentsToRegister()
getComponentsToRegister in interface ComponentsRegistration