クラス ListenerContainerFactoryBean
java.lang.ObjectSE
org.springframework.beans.factory.config.AbstractFactoryBean<AbstractMessageListenerContainer>
org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- 実装されたすべてのインターフェース:
Aware
、BeanClassLoaderAware
、BeanFactoryAware
、BeanNameAware
、DisposableBean
、FactoryBean<AbstractMessageListenerContainer>
、InitializingBean
、ApplicationContextAware
、ApplicationEventPublisherAware
、Lifecycle
、Phased
、SmartLifecycle
public class ListenerContainerFactoryBean
extends AbstractFactoryBean<AbstractMessageListenerContainer>
implements ApplicationContextAware, BeanNameAware, ApplicationEventPublisherAware, SmartLifecycle
リスナーコンテナーを作成するためのファクトリ Bean。
- 導入:
- 2.0
- 作成者:
- Gary Russell, Artem Bilan, Johno Crawford, Jeonggi Kim
ネストされたクラスのサマリー
フィールドサマリー
クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたフィールド
logger
インターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTE
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターのサマリー
メソッドのサマリー
修飾子と型メソッド説明protected AbstractMessageListenerContainer
ClassSE<?>
int
getPhase()
boolean
boolean
void
setAcknowledgeMode
(AcknowledgeMode acknowledgeMode) void
setAdviceChain
(Advice... adviceChain) void
setAfterReceivePostProcessors
(MessagePostProcessor... afterReceivePostProcessors) void
setApplicationContext
(ApplicationContext applicationContext) void
setApplicationEventPublisher
(ApplicationEventPublisher applicationEventPublisher) void
setAutoDeclare
(boolean autoDeclare) void
setAutoStartup
(boolean autoStartup) void
setBatchReceiveTimeout
(long batchReceiveTimeout) バッチメッセージを収集するためのタイムアウトのミリ秒数。void
setBatchSize
(int batchSize) このプロパティにはいくつかの機能があります。void
setBeanName
(StringSE beanName) void
setChannelTransacted
(boolean transactional) void
setConcurrentConsumers
(int concurrentConsumers) void
setConnectionFactory
(ConnectionFactory connectionFactory) void
setConsecutiveActiveTrigger
(int consecutiveActiveTrigger) void
setConsecutiveIdleTrigger
(int consecutiveIdleTrigger) void
void
setConsumerBatchEnabled
(boolean consumerBatchEnabled) コンテナーとリスナーがサポートしている場合、setBatchSize(int)
に基づいてメッセージのリストを表示するには、true に設定します。void
setConsumersPerQueue
(int consumersPerQueue) void
setConsumerTagStrategy
(ConsumerTagStrategy consumerTagStrategy) void
setDeBatchingEnabled
(boolean deBatchingEnabled) void
setDeclarationRetries
(int declarationRetries) void
setDefaultRequeueRejected
(boolean defaultRequeueRejected) void
コンテナーの作成および構成後に呼び出されるContainerCustomizer
を設定して、コンテナーをさらにカスタマイズできるようにします。void
setErrorHandler
(ErrorHandler errorHandler) void
setExclusive
(boolean exclusive) void
setExclusiveConsumerExceptionLogger
(ConditionalExceptionLogger exclusiveConsumerExceptionLogger) void
setExposeListenerChannel
(boolean exposeListenerChannel) void
setFailedDeclarationRetryInterval
(long failedDeclarationRetryInterval) void
setGlobalQos
(boolean globalQos) チャネル全体にプリフェッチを適用します。void
setIdleEventInterval
(long idleEventInterval) void
setListenerId
(StringSE listenerId) void
setMaxConcurrentConsumers
(int maxConcurrentConsumers) void
setMessageListener
(MessageListener messageListener) void
setMessagePropertiesConverter
(MessagePropertiesConverter messagePropertiesConverter) void
setMicrometerEnabled
(boolean enabled) micrometer リスナータイマーを無効にするには、false に設定します。void
setMicrometerTags
(MapSE<StringSE, StringSE> tags) Micrometer リスナータイマーに追加のタグを設定します。void
setMismatchedQueuesFatal
(boolean mismatchedQueuesFatal) void
setMissingQueuesFatal
(boolean missingQueuesFatal) void
setMonitorInterval
(long monitorInterval) void
setNoLocal
(BooleanSE noLocal) void
setPhase
(int phase) void
setPossibleAuthenticationFailureFatal
(BooleanSE possibleAuthenticationFailureFatal) void
setPrefetchCount
(int prefetchCount) void
setQueueNames
(StringSE... queueName) void
void
setRabbitAdmin
(RabbitAdmin rabbitAdmin) void
setReceiveTimeout
(long receiveTimeout) void
setRecoveryBackOff
(BackOff recoveryBackOff) void
setRecoveryInterval
(long recoveryInterval) void
setRetryDeclarationInterval
(long retryDeclarationInterval) void
setShutdownTimeout
(long shutdownTimeout) void
コンテナーの作成および構成後に呼び出されるContainerCustomizer
を設定して、コンテナーをさらにカスタマイズできるようにします。void
setStartConsumerMinInterval
(long startConsumerMinInterval) void
setStopConsumerMinInterval
(long stopConsumerMinInterval) void
setTaskExecutor
(ExecutorSE taskExecutor) void
setTaskScheduler
(TaskScheduler taskScheduler) void
setTransactionAttribute
(TransactionAttribute transactionAttribute) void
setTransactionManager
(PlatformTransactionManager transactionManager) void
void
start()
void
stop()
void
stop
(RunnableSE callback) クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたメソッド
afterPropertiesSet, destroy, destroyInstance, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
コンストラクターの詳細
ListenerContainerFactoryBean
public ListenerContainerFactoryBean()
メソッドの詳細
setApplicationEventPublisher
- 次で指定:
- インターフェース
ApplicationEventPublisherAware
のsetApplicationEventPublisher
setBeanName
- 次で指定:
- インターフェース
BeanNameAware
のsetBeanName
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAware
のsetApplicationContext
- 例外:
BeansException
setType
setConnectionFactory
setChannelTransacted
public void setChannelTransacted(boolean transactional) setAcknowledgeMode
setQueueNames
setQueues
setExposeListenerChannel
public void setExposeListenerChannel(boolean exposeListenerChannel) setMessageListener
setErrorHandler
setDeBatchingEnabled
public void setDeBatchingEnabled(boolean deBatchingEnabled) setAdviceChain
setAfterReceivePostProcessors
setAutoStartup
public void setAutoStartup(boolean autoStartup) setPhase
public void setPhase(int phase) setListenerId
setConsumerTagStrategy
setConsumerArguments
setNoLocal
setExclusive
public void setExclusive(boolean exclusive) setDefaultRequeueRejected
public void setDefaultRequeueRejected(boolean defaultRequeueRejected) setPrefetchCount
public void setPrefetchCount(int prefetchCount) setGlobalQos
public void setGlobalQos(boolean globalQos) チャネル全体にプリフェッチを適用します。- パラメーター:
globalQos
- チャネル全体のプリフェッチの場合は true。- 導入:
- 2.2.17
- 関連事項:
Channel.basicQos(int, boolean)
setShutdownTimeout
public void setShutdownTimeout(long shutdownTimeout) setIdleEventInterval
public void setIdleEventInterval(long idleEventInterval) setTransactionManager
setTransactionAttribute
setTaskExecutor
setRecoveryInterval
public void setRecoveryInterval(long recoveryInterval) setRecoveryBackOff
setMessagePropertiesConverter
setRabbitAdmin
setMissingQueuesFatal
public void setMissingQueuesFatal(boolean missingQueuesFatal) setPossibleAuthenticationFailureFatal
setMismatchedQueuesFatal
public void setMismatchedQueuesFatal(boolean mismatchedQueuesFatal) setAutoDeclare
public void setAutoDeclare(boolean autoDeclare) setFailedDeclarationRetryInterval
public void setFailedDeclarationRetryInterval(long failedDeclarationRetryInterval) setExclusiveConsumerExceptionLogger
public void setExclusiveConsumerExceptionLogger(ConditionalExceptionLogger exclusiveConsumerExceptionLogger) setConsumersPerQueue
public void setConsumersPerQueue(int consumersPerQueue) setTaskScheduler
setMonitorInterval
public void setMonitorInterval(long monitorInterval) setConcurrentConsumers
public void setConcurrentConsumers(int concurrentConsumers) setMaxConcurrentConsumers
public void setMaxConcurrentConsumers(int maxConcurrentConsumers) setStartConsumerMinInterval
public void setStartConsumerMinInterval(long startConsumerMinInterval) setStopConsumerMinInterval
public void setStopConsumerMinInterval(long stopConsumerMinInterval) setConsecutiveActiveTrigger
public void setConsecutiveActiveTrigger(int consecutiveActiveTrigger) setConsecutiveIdleTrigger
public void setConsecutiveIdleTrigger(int consecutiveIdleTrigger) setReceiveTimeout
public void setReceiveTimeout(long receiveTimeout) setBatchReceiveTimeout
public void setBatchReceiveTimeout(long batchReceiveTimeout) バッチメッセージを収集するためのタイムアウトのミリ秒数。batchSize がいっぱいになるまでの待機時間を制限します。デフォルトは 0 (タイムアウトなし) です。- パラメーター:
batchReceiveTimeout
- バッチメッセージを収集するためのタイムアウト。- 導入:
- 3.1.2
- 関連事項:
setBatchSize
public void setBatchSize(int batchSize) このプロパティにはいくつかの機能があります。チャネルが処理されると、1 つのトランザクションで処理するメッセージの数が決定されます。
the prefetch count
以下である必要があります。また、
AcknowledgeMode.AUTO
を使用する場合に ACK が送信される頻度にも影響します (BatchSize ごとに 1 つの ACK)。最後に、
setConsumerBatchEnabled(boolean)
が true の場合、setReceiveTimeout(long)
内に十分なメッセージが到着する限り、バッチに含めるレコードの数を決定します。重要バッチサイズは、受信した物理メッセージの数を表します。
setDeBatchingEnabled(boolean)
が true で、メッセージがプロデューサーによって作成されたバッチである場合、リスナーによって受信される実際のメッセージ数は、このバッチサイズよりも大きくなります。デフォルトは 1 です。
- パラメーター:
batchSize
- バッチサイズ- 導入:
- 2.2
setConsumerBatchEnabled
public void setConsumerBatchEnabled(boolean consumerBatchEnabled) コンテナーとリスナーがサポートしている場合、setBatchSize(int)
に基づいてメッセージのリストを表示するには、true に設定します。- パラメーター:
consumerBatchEnabled
- コンテナーにメッセージバッチを作成する場合は true。- 導入:
- 2.2
- 関連事項:
setDeclarationRetries
public void setDeclarationRetries(int declarationRetries) setRetryDeclarationInterval
public void setRetryDeclarationInterval(long retryDeclarationInterval) setMicrometerEnabled
public void setMicrometerEnabled(boolean enabled) micrometer リスナータイマーを無効にするには、false に設定します。- パラメーター:
enabled
- 無効にする場合は false。- 導入:
- 2.4.6
setMicrometerTags
Micrometer リスナータイマーに追加のタグを設定します。- パラメーター:
tags
- タグ。- 導入:
- 2.4.6
setSMLCCustomizer
コンテナーの作成および構成後に呼び出されるContainerCustomizer
を設定して、コンテナーをさらにカスタマイズできるようにします。- パラメーター:
customizer
- カスタマイザー。- 導入:
- 2.4.6
setDMLCCustomizer
コンテナーの作成および構成後に呼び出されるContainerCustomizer
を設定して、コンテナーをさらにカスタマイズできるようにします。- パラメーター:
customizer
- カスタマイザー。- 導入:
- 2.4.6
getObjectType
- 次で指定:
- インターフェース
FactoryBean<AbstractMessageListenerContainer>
のgetObjectType
- 次で指定:
- クラス
AbstractFactoryBean<AbstractMessageListenerContainer>
のgetObjectType
createInstance
start
public void start()stop
public void stop()isRunning
public boolean isRunning()getPhase
public int getPhase()- 次で指定:
- インターフェース
Phased
のgetPhase
- 次で指定:
- インターフェース
SmartLifecycle
のgetPhase
isAutoStartup
public boolean isAutoStartup()- 次で指定:
- インターフェース
SmartLifecycle
のisAutoStartup
stop
- 次で指定:
- インターフェース
SmartLifecycle
のstop