クラス AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>
java.lang.ObjectSE
org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<C>
org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory<C>
- 型パラメーター:
C
- コンテナー型。
- 実装されたすべてのインターフェース:
RabbitListenerContainerFactory<C>
、Aware
、ApplicationContextAware
、ApplicationEventPublisherAware
public abstract class AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>
extends BaseRabbitListenerContainerFactory<C>
implements ApplicationContextAware, ApplicationEventPublisherAware
Spring の基本コンテナー実装の
RabbitListenerContainerFactory
。- 導入:
- 1.4
- 作成者:
- Stephane Nicoll, Gary Russell, Artem Bilan, Joris Kuipers
- 関連事項:
フィールドサマリー
フィールドコンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected abstract C
空のコンテナーインスタンスを作成します。指定されたRabbitListenerEndpoint
のMessageListenerContainer
を作成します。protected void
initializeContainer
(C instance, RabbitListenerEndpoint endpoint) さらに、指定されたコンテナーを初期化します。void
setAcknowledgeMode
(AcknowledgeMode acknowledgeMode) void
setAfterReceivePostProcessors
(MessagePostProcessor... postProcessors) メッセージの受信後に適用されるポストプロセッサーを設定します。void
setApplicationEventPublisher
(ApplicationEventPublisher applicationEventPublisher) void
setAutoStartup
(BooleanSE autoStartup) void
setBatchingStrategy
(BatchingStrategy batchingStrategy) メッセージのデバッチ時に使用するBatchingStrategy
を設定します。void
setBatchListener
(boolean isBatch) BatchingRabbitTemplate
によって作成された、デバッチされたメッセージのリストを受け取るには、true に設定します。void
setChannelTransacted
(BooleanSE channelTransacted) void
setConnectionFactory
(ConnectionFactory connectionFactory) void
setConsumerTagStrategy
(ConsumerTagStrategy consumerTagStrategy) void
setContainerCustomizer
(ContainerCustomizer<C> containerCustomizer) コンテナーの作成および構成後に呼び出されるContainerCustomizer
を設定して、コンテナーをさらにカスタマイズできるようにします。void
setDeBatchingEnabled
(BooleanSE deBatchingEnabled) コンテナーがバッチ処理されたメッセージのバッチ処理を解除するか(true)、バッチを使用してリスナーを呼び出すか(false)を決定します。void
setErrorHandler
(ErrorHandler errorHandler) void
setFailedDeclarationRetryInterval
(LongSE failedDeclarationRetryInterval) void
setForceStop
(boolean forceStop) 現在のメッセージが処理された後にコンテナーを停止し、プリフェッチされたメッセージを再度キューに入れるには true に設定します。void
setGlobalQos
(boolean globalQos) チャネル全体にプリフェッチを適用します。void
setIdleEventInterval
(LongSE idleEventInterval) アイドル状態のコンテナーイベントを公開する頻度。void
setMessageAckListener
(MessageAckListener messageAckListener) AcknowledgeMode.AUTO
モードでメッセージ (メッセージ) を確認するときに使用するMessageAckListener
を設定します。void
setMessageConverter
(MessageConverter messageConverter) void
setMismatchedQueuesFatal
(BooleanSE mismatchedQueuesFatal) void
setMissingQueuesFatal
(BooleanSE missingQueuesFatal) void
setObservationConvention
(RabbitListenerObservationConvention observationConvention) 観察規則を設定します。観測に追加のキー / 値を追加するために使用されます。void
setPhase
(int phase) void
setPrefetchCount
(IntegerSE prefetch) void
setRecoveryBackOff
(BackOff recoveryBackOff) void
setRecoveryInterval
(LongSE recoveryInterval) void
setTaskExecutor
(ExecutorSE taskExecutor) void
setTransactionManager
(PlatformTransactionManager transactionManager) クラス org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory から継承されたメソッド
applyCommonOverrides, getAdviceChain, getApplicationContext, getDefaultRequeueRejected, getMicrometerEnabled, getObservationEnabled, setAdviceChain, setApplicationContext, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setMicrometerEnabled, setObservationEnabled, setReplyPostProcessorProvider, setReplyRecoveryCallback, setRetryTemplate
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.context.ApplicationContextAware から継承されたメソッド
setApplicationContext
インターフェース org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory から継承されたメソッド
createListenerContainer
フィールドの詳細
logger
counter
コンストラクターの詳細
AbstractRabbitListenerContainerFactory
public AbstractRabbitListenerContainerFactory()
メソッドの詳細
setConnectionFactory
- パラメーター:
connectionFactory
- 接続ファクトリ。- 関連事項:
setErrorHandler
- パラメーター:
errorHandler
- エラーハンドラー。- 関連事項:
setMessageConverter
- パラメーター:
messageConverter
- 使用するメッセージコンバーター- 関連事項:
setAcknowledgeMode
- パラメーター:
acknowledgeMode
- 設定する確認モード。デフォルトはAcknowledgeMode.AUTO
- 関連事項:
setChannelTransacted
- パラメーター:
channelTransacted
- 設定するフラグ値- 関連事項:
setTaskExecutor
- パラメーター:
taskExecutor
- 使用するExecutor
SE。- 関連事項:
setTransactionManager
- パラメーター:
transactionManager
- 使用するPlatformTransactionManager
。- 関連事項:
setPrefetchCount
- パラメーター:
prefetch
- プリフェッチ数- 関連事項:
setRecoveryInterval
- パラメーター:
recoveryInterval
- 回復間隔。- 関連事項:
setRecoveryBackOff
- パラメーター:
recoveryBackOff
- 回復する BackOff。- 導入:
- 1.5
- 関連事項:
setMissingQueuesFatal
- パラメーター:
missingQueuesFatal
- 設定する missingQueuesFatal- 関連事項:
setMismatchedQueuesFatal
- パラメーター:
mismatchedQueuesFatal
- 設定する mismatchedQueuesFatal。- 導入:
- 1.6
- 関連事項:
setConsumerTagStrategy
- パラメーター:
consumerTagStrategy
- 設定する consumerTagStrategy- 関連事項:
setIdleEventInterval
アイドル状態のコンテナーイベントを公開する頻度。- パラメーター:
idleEventInterval
- 間隔。
setFailedDeclarationRetryInterval
setApplicationEventPublisher
- 次で指定:
- インターフェース
ApplicationEventPublisherAware
のsetApplicationEventPublisher
setAutoStartup
- パラメーター:
autoStartup
- 自動起動の場合は true。- 関連事項:
setPhase
public void setPhase(int phase) - パラメーター:
phase
- フェーズ。- 関連事項:
setAfterReceivePostProcessors
メッセージの受信後に適用されるポストプロセッサーを設定します。- パラメーター:
postProcessors
- ポストプロセッサー。- 導入:
- 2.0
- 関連事項:
setContainerCustomizer
コンテナーの作成および構成後に呼び出されるContainerCustomizer
を設定して、コンテナーをさらにカスタマイズできるようにします。- パラメーター:
containerCustomizer
- カスタマイザー。- 導入:
- 2.2.2
setBatchListener
public void setBatchListener(boolean isBatch) BatchingRabbitTemplate
によって作成された、デバッチされたメッセージのリストを受け取るには、true に設定します。- パラメーター:
isBatch
- バッチリスナーの場合は true。- 導入:
- 2.2
- 関連事項:
setBatchingStrategy
メッセージのデバッチ時に使用するBatchingStrategy
を設定します。- パラメーター:
batchingStrategy
- バッチ戦略。- 導入:
- 2.2
- 関連事項:
setDeBatchingEnabled
コンテナーがバッチ処理されたメッセージのバッチ処理を解除するか(true)、バッチを使用してリスナーを呼び出すか(false)を決定します。デフォルト: true。- パラメーター:
deBatchingEnabled
- メッセージのデバッチを無効にするかどうか。- 導入:
- 2.2
- 関連事項:
setGlobalQos
public void setGlobalQos(boolean globalQos) チャネル全体にプリフェッチを適用します。- パラメーター:
globalQos
- チャネル全体のプリフェッチの場合は true。- 導入:
- 2.2.17
- 関連事項:
Channel.basicQos(int, boolean)
setMessageAckListener
AcknowledgeMode.AUTO
モードでメッセージ (メッセージ) を確認するときに使用するMessageAckListener
を設定します。- パラメーター:
messageAckListener
- メッセージ AckListener。- 導入:
- 2.4.6
setObservationConvention
観察規則を設定します。観測に追加のキー / 値を追加するために使用されます。- パラメーター:
observationConvention
- 大会。- 導入:
- 3.0
setForceStop
public void setForceStop(boolean forceStop) 現在のメッセージが処理された後にコンテナーを停止し、プリフェッチされたメッセージを再度キューに入れるには true に設定します。排他的または単一アクティブなコンシューマーを使用する場合に便利です。- パラメーター:
forceStop
- 現在のメッセージが処理されたときに停止する場合は true。- 導入:
- 2.4.15
createListenerContainer
インターフェースからコピーされた説明:RabbitListenerContainerFactory
指定されたRabbitListenerEndpoint
のMessageListenerContainer
を作成します。- 次で指定:
- インターフェース
RabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>
のcreateListenerContainer
- 次で指定:
- クラス
BaseRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>
のcreateListenerContainer
- パラメーター:
endpoint
- 構成するエンドポイント。- 戻り値:
- 作成したコンテナー。
createContainerInstance
空のコンテナーインスタンスを作成します。- 戻り値:
- 新しいコンテナーインスタンス。
initializeContainer
さらに、指定されたコンテナーを初期化します。サブクラスはこのメソッドを継承して、必要に応じて追加の構成を適用できます。
- パラメーター:
instance
- 構成するコンテナーインスタンス。endpoint
- エンドポイント。