public class AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S>> extends AmqpPollableMessageChannelSpec<S>
amqpChannelFactoryBean
channel
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
S |
acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode) |
S |
advice(org.aopalliance.aop.Advice... advice) |
S |
autoStartup(boolean autoStartup) |
S |
concurrentConsumers(int concurrentConsumers) |
protected org.springframework.integration.amqp.channel.AbstractAmqpChannel |
doGet() |
S |
errorHandler(org.springframework.util.ErrorHandler errorHandler) |
S |
exposeListenerChannel(boolean exposeListenerChannel) |
S |
maxSubscribers(int maxSubscribers) |
S |
phase(int phase) |
S |
prefetchCount(int prefetchCount) |
S |
receiveTimeout(long receiveTimeout) |
S |
recoveryInterval(long recoveryInterval) |
S |
shutdownTimeout(long shutdownTimeout) |
S |
taskExecutor(java.util.concurrent.Executor taskExecutor) |
S |
transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) |
S |
transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
S |
txSize(int txSize) |
amqpMessageConverter, channelTransacted, encoding, id, messagePropertiesConverter, queueName
datatype, interceptor, messageConverter
_this, get, getId
public S maxSubscribers(int maxSubscribers)
public S acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
public S advice(org.aopalliance.aop.Advice... advice)
public S autoStartup(boolean autoStartup)
public S concurrentConsumers(int concurrentConsumers)
public S errorHandler(org.springframework.util.ErrorHandler errorHandler)
public S exposeListenerChannel(boolean exposeListenerChannel)
public S phase(int phase)
public S prefetchCount(int prefetchCount)
public S receiveTimeout(long receiveTimeout)
public S recoveryInterval(long recoveryInterval)
public S shutdownTimeout(long shutdownTimeout)
public S taskExecutor(java.util.concurrent.Executor taskExecutor)
public S transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
public S transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public S txSize(int txSize)
protected org.springframework.integration.amqp.channel.AbstractAmqpChannel doGet()
doGet
in class AmqpPollableMessageChannelSpec<S extends AmqpMessageChannelSpec<S>>