public class AmqpInboundGatewaySpec extends MessagingGatewaySpec<AmqpInboundGatewaySpec,org.springframework.integration.amqp.inbound.AmqpInboundGateway>
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
AmqpInboundGatewaySpec |
acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode) |
AmqpInboundGatewaySpec |
addQueueNames(java.lang.String... queueName) |
AmqpInboundGatewaySpec |
addQueues(org.springframework.amqp.core.Queue... queues) |
AmqpInboundGatewaySpec |
adviceChain(org.aopalliance.aop.Advice... adviceChain) |
AmqpInboundGatewaySpec |
channelTransacted(boolean transactional) |
AmqpInboundGatewaySpec |
concurrentConsumers(int concurrentConsumers) |
AmqpInboundGatewaySpec |
consecutiveActiveTrigger(int consecutiveActiveTrigger) |
AmqpInboundGatewaySpec |
consecutiveIdleTrigger(int consecutiveIdleTrigger) |
AmqpInboundGatewaySpec |
defaultRequeueRejected(boolean defaultRequeueRejected) |
AmqpInboundGatewaySpec |
errorHandler(org.springframework.util.ErrorHandler errorHandler) |
AmqpInboundGatewaySpec |
exclusive(boolean exclusive) |
AmqpInboundGatewaySpec |
headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper) |
AmqpInboundGatewaySpec |
mappedReplyHeaders(java.lang.String... headers) |
AmqpInboundGatewaySpec |
mappedRequestHeaders(java.lang.String... headers) |
AmqpInboundGatewaySpec |
maxConcurrentConsumers(int maxConcurrentConsumers) |
AmqpInboundGatewaySpec |
messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter) |
AmqpInboundGatewaySpec |
prefetchCount(int prefetchCount) |
AmqpInboundGatewaySpec |
receiveTimeout(long receiveTimeout) |
AmqpInboundGatewaySpec |
recoveryInterval(long recoveryInterval) |
AmqpInboundGatewaySpec |
shutdownTimeout(long shutdownTimeout) |
AmqpInboundGatewaySpec |
startConsumerMinInterval(long startConsumerMinInterval) |
AmqpInboundGatewaySpec |
stopConsumerMinInterval(long stopConsumerMinInterval) |
AmqpInboundGatewaySpec |
taskExecutor(java.util.concurrent.Executor taskExecutor) |
AmqpInboundGatewaySpec |
transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
AmqpInboundGatewaySpec |
txSize(int txSize) |
autoStartup, doGet, errorChannel, id, phase, replyChannel, replyMapper, replyTimeout, requestChannel, requestMapper, requestTimeout
_this, get, getId
public AmqpInboundGatewaySpec acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
public AmqpInboundGatewaySpec addQueueNames(java.lang.String... queueName)
public AmqpInboundGatewaySpec addQueues(org.springframework.amqp.core.Queue... queues)
public AmqpInboundGatewaySpec errorHandler(org.springframework.util.ErrorHandler errorHandler)
public AmqpInboundGatewaySpec channelTransacted(boolean transactional)
public AmqpInboundGatewaySpec adviceChain(org.aopalliance.aop.Advice... adviceChain)
public AmqpInboundGatewaySpec recoveryInterval(long recoveryInterval)
public AmqpInboundGatewaySpec concurrentConsumers(int concurrentConsumers)
public AmqpInboundGatewaySpec maxConcurrentConsumers(int maxConcurrentConsumers)
public AmqpInboundGatewaySpec exclusive(boolean exclusive)
public AmqpInboundGatewaySpec startConsumerMinInterval(long startConsumerMinInterval)
public AmqpInboundGatewaySpec stopConsumerMinInterval(long stopConsumerMinInterval)
public AmqpInboundGatewaySpec consecutiveActiveTrigger(int consecutiveActiveTrigger)
public AmqpInboundGatewaySpec consecutiveIdleTrigger(int consecutiveIdleTrigger)
public AmqpInboundGatewaySpec receiveTimeout(long receiveTimeout)
public AmqpInboundGatewaySpec shutdownTimeout(long shutdownTimeout)
public AmqpInboundGatewaySpec taskExecutor(java.util.concurrent.Executor taskExecutor)
public AmqpInboundGatewaySpec prefetchCount(int prefetchCount)
public AmqpInboundGatewaySpec txSize(int txSize)
public AmqpInboundGatewaySpec transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public AmqpInboundGatewaySpec defaultRequeueRejected(boolean defaultRequeueRejected)
public AmqpInboundGatewaySpec messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
public AmqpInboundGatewaySpec headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper)
public AmqpInboundGatewaySpec mappedRequestHeaders(java.lang.String... headers)
public AmqpInboundGatewaySpec mappedReplyHeaders(java.lang.String... headers)