S
- ターゲット AmqpMessageChannelSpec
実装型。public class AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S,T>,T extends AbstractAmqpChannel> extends AmqpPollableMessageChannelSpec<S,T>
修飾子と型 | フィールドと説明 |
---|---|
protected ListSE<Advice> | adviceChain |
amqpChannelFactoryBean
channel
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
修飾子 | コンストラクターと説明 |
---|---|
protected | AmqpMessageChannelSpec(ConnectionFactory connectionFactory) |
修飾子と型 | メソッドと説明 |
---|---|
S | acknowledgeMode(AcknowledgeMode acknowledgeMode) |
S | advice(Advice... advice) |
S | autoStartup(boolean autoStartup) |
S | batchSize(int batchSize) バッチサイズを構成します。 |
S | concurrentConsumers(int concurrentConsumers) |
protected T | doGet() |
S | errorHandler(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(ExecutorSE taskExecutor) メッセージリスナーの呼び出しに使用する Executor SE を設定します。 |
S | transactionAttribute(TransactionAttribute transactionAttribute) transactionManager(PlatformTransactionManager) で使用するように TransactionAttribute を構成します。 |
S | transactionManager(PlatformTransactionManager transactionManager) PlatformTransactionManager を構成します。; rabbit トランザクションを他のトランザクションと同期するために使用されます。 |
amqpMessageConverter, channelTransacted, defaultDeliveryMode, encoding, extractPayload, headersMappedLast, id, inboundHeaderMapper, messagePropertiesConverter, outboundHeaderMapper, queueName, templateChannelTransacted
datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
protected AmqpMessageChannelSpec(ConnectionFactory connectionFactory)
public S maxSubscribers(int maxSubscribers)
maxSubscribers
- maxSubscribers。AbstractSubscribableAmqpChannel.setMaxSubscribers(int)
public S acknowledgeMode(AcknowledgeMode acknowledgeMode)
acknowledgeMode
- acknowledgeMode。AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)
public S advice(Advice... advice)
advice
- 助言。AbstractMessageListenerContainer.setAdviceChain(Advice[])
public S autoStartup(boolean autoStartup)
autoStartup
- autoStartup。SmartLifecycle
public S concurrentConsumers(int concurrentConsumers)
concurrentConsumers
- concurrentConsumersSimpleMessageListenerContainer.setConcurrentConsumers(int)
public S errorHandler(ErrorHandler errorHandler)
errorHandler
- errorHandler。AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)
public S exposeListenerChannel(boolean exposeListenerChannel)
exposeListenerChannel
- exposeListenerChannel。AbstractMessageListenerContainer.setExposeListenerChannel(boolean)
public S phase(int phase)
phase
- フェーズ。SmartLifecycle
public S prefetchCount(int prefetchCount)
prefetchCount
- prefetchCount。AbstractMessageListenerContainer.setPrefetchCount(int)
public S receiveTimeout(long receiveTimeout)
receiveTimeout
- receiveTimeoutSimpleMessageListenerContainer.setReceiveTimeout(long)
public S recoveryInterval(long recoveryInterval)
recoveryInterval
- recoveryIntervalAbstractMessageListenerContainer.setRecoveryInterval(long)
public S shutdownTimeout(long shutdownTimeout)
shutdownTimeout
- shutdownTimeout。AbstractMessageListenerContainer.setShutdownTimeout(long)
public S taskExecutor(ExecutorSE taskExecutor)
Executor
SE を設定します。taskExecutor
- taskExecutor。public S transactionAttribute(TransactionAttribute transactionAttribute)
transactionManager(PlatformTransactionManager)
で使用するように TransactionAttribute
を構成します。transactionAttribute
- transactionAttribute。public S transactionManager(PlatformTransactionManager transactionManager)
PlatformTransactionManager
を構成します。; rabbit トランザクションを他のトランザクションと同期するために使用されます。transactionManager
- transactionManager。public S batchSize(int batchSize)
batchSize
- batchSize。SimpleMessageListenerContainer.setBatchSize(int)
protected T doGet()
AmqpPollableMessageChannelSpec<S extends AmqpMessageChannelSpec<S, T>,T extends AbstractAmqpChannel>
の doGet