S - ターゲット AmqpMessageChannelSpec 実装型。public class AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S,T>,T extends AbstractAmqpChannel> extends AmqpPollableMessageChannelSpec<S,T>
| 修飾子と型 | フィールドと説明 |
|---|---|
protected ListSE<Advice> | adviceChain |
amqpChannelFactoryBeanchannelPARSER, targetloggerDEFAULT_PHASEOBJECT_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) メッセージリスナーの呼び出しに使用する ExecutorSE を設定します。 |
S | transactionAttribute(TransactionAttribute transactionAttribute)transactionManager(PlatformTransactionManager) で使用するように TransactionAttribute を構成します。 |
S | transactionManager(PlatformTransactionManager transactionManager)PlatformTransactionManager を構成します。; rabbit トランザクションを他のトランザクションと同期するために使用されます。 |
amqpMessageConverter, channelTransacted, defaultDeliveryMode, encoding, extractPayload, headersMappedLast, id, inboundHeaderMapper, messagePropertiesConverter, outboundHeaderMapper, queueName, templateChannelTransacteddatatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected 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。SmartLifecyclepublic 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 - フェーズ。SmartLifecyclepublic 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)
ExecutorSE を設定します。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