クラス 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
- 関連事項:
AbstractMessageListenerContainer
フィールドサマリー
フィールド 修飾子と型 フィールド 説明 protected AtomicIntegerSE
counter
protected Log
logger
コンストラクターのサマリー
コンストラクター コンストラクター 説明 AbstractRabbitListenerContainerFactory()
メソッドのサマリー
すべてのメソッド インスタンスメソッド 抽象メソッド 具象メソッド 修飾子と型 メソッド 説明 protected abstract C
createContainerInstance()
空のコンテナーインスタンスを作成します。C
createListenerContainer(RabbitListenerEndpoint endpoint)
指定されたRabbitListenerEndpoint
のMessageListenerContainer
を作成します。Advice[]
getAdviceChain()
protected void
initializeContainer(C instance, RabbitListenerEndpoint endpoint)
さらに、指定されたコンテナーを初期化します。void
setAcknowledgeMode(AcknowledgeMode acknowledgeMode)
void
setAdviceChain(Advice... adviceChain)
void
setAfterReceivePostProcessors(MessagePostProcessor... postProcessors)
メッセージの受信後に適用されるポストプロセッサーを設定します。void
setApplicationContext(ApplicationContext applicationContext)
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
setGlobalQos(boolean globalQos)
チャネル全体にプリフェッチを適用します。void
setIdleEventInterval(LongSE idleEventInterval)
アイドル状態のコンテナーイベントを公開する頻度。void
setMessageConverter(MessageConverter messageConverter)
void
setMismatchedQueuesFatal(BooleanSE mismatchedQueuesFatal)
void
setMissingQueuesFatal(BooleanSE missingQueuesFatal)
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, getDefaultRequeueRejected, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setReplyRecoveryCallback, setRetryTemplate
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory から継承されたメソッド
createListenerContainer
フィールドの詳細
logger
protected final Log logger
counter
protected final AtomicIntegerSE counter
メソッドの詳細
setConnectionFactory
public void setConnectionFactory(ConnectionFactory connectionFactory)
- パラメーター:
connectionFactory
- 接続ファクトリ。- 関連事項:
RabbitAccessor.setConnectionFactory(ConnectionFactory)
setErrorHandler
public void setErrorHandler(ErrorHandler errorHandler)
- パラメーター:
errorHandler
- エラーハンドラー。- 関連事項:
AbstractMessageListenerContainer.setErrorHandler(org.springframework.util.ErrorHandler)
setMessageConverter
public void setMessageConverter(MessageConverter messageConverter)
- パラメーター:
messageConverter
- 使用するメッセージコンバーター- 関連事項:
RabbitListenerEndpoint.setMessageConverter(MessageConverter)
setAcknowledgeMode
public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)
- パラメーター:
acknowledgeMode
- 設定する確認モード。デフォルトはAcknowledgeMode.AUTO
- 関連事項:
AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)
setChannelTransacted
public void setChannelTransacted(BooleanSE channelTransacted)
- パラメーター:
channelTransacted
- 設定するフラグ値- 関連事項:
RabbitAccessor.setChannelTransacted(boolean)
setTaskExecutor
public void setTaskExecutor(ExecutorSE taskExecutor)
- パラメーター:
taskExecutor
- 使用するExecutor
SE。- 関連事項:
AbstractMessageListenerContainer.setTaskExecutor(java.util.concurrent.Executor)
setTransactionManager
public void setTransactionManager(PlatformTransactionManager transactionManager)
- パラメーター:
transactionManager
- 使用するPlatformTransactionManager
。- 関連事項:
AbstractMessageListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)
setPrefetchCount
public void setPrefetchCount(IntegerSE prefetch)
- パラメーター:
prefetch
- プリフェッチ数- 関連事項:
AbstractMessageListenerContainer.setPrefetchCount(int)
getAdviceChain
@Nullable public Advice[] getAdviceChain()
- 戻り値:
- 設定されたアドバイスチェーン。デフォルトは
null
です。 - 導入:
- 1.7.4
setAdviceChain
public void setAdviceChain(Advice... adviceChain)
- パラメーター:
adviceChain
- 設定するアドバイスチェーン。- 関連事項:
AbstractMessageListenerContainer.setAdviceChain(org.aopalliance.aop.Advice...)
setRecoveryInterval
public void setRecoveryInterval(LongSE recoveryInterval)
- パラメーター:
recoveryInterval
- 回復間隔。- 関連事項:
AbstractMessageListenerContainer.setRecoveryInterval(long)
setRecoveryBackOff
public void setRecoveryBackOff(BackOff recoveryBackOff)
- パラメーター:
recoveryBackOff
- 回復する BackOff。- 導入:
- 1.5
- 関連事項:
AbstractMessageListenerContainer.setRecoveryBackOff(BackOff)
setMissingQueuesFatal
public void setMissingQueuesFatal(BooleanSE missingQueuesFatal)
- パラメーター:
missingQueuesFatal
- 設定する missingQueuesFatal- 関連事項:
AbstractMessageListenerContainer.setMissingQueuesFatal(boolean)
setMismatchedQueuesFatal
public void setMismatchedQueuesFatal(BooleanSE mismatchedQueuesFatal)
- パラメーター:
mismatchedQueuesFatal
- 設定する mismatchedQueuesFatal。- 導入:
- 1.6
- 関連事項:
AbstractMessageListenerContainer.setMismatchedQueuesFatal(boolean)
setConsumerTagStrategy
public void setConsumerTagStrategy(ConsumerTagStrategy consumerTagStrategy)
- パラメーター:
consumerTagStrategy
- 設定する consumerTagStrategy- 関連事項:
AbstractMessageListenerContainer.setConsumerTagStrategy(ConsumerTagStrategy)
setIdleEventInterval
public void setIdleEventInterval(LongSE idleEventInterval)
アイドル状態のコンテナーイベントを公開する頻度。- パラメーター:
idleEventInterval
- 間隔。
setFailedDeclarationRetryInterval
public void setFailedDeclarationRetryInterval(LongSE failedDeclarationRetryInterval)
setApplicationEventPublisher
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
- 次で指定:
- インターフェース
ApplicationEventPublisherAware
のsetApplicationEventPublisher
setApplicationContext
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
- 次で指定:
- インターフェース
ApplicationContextAware
のsetApplicationContext
- 例外:
BeansException
setAutoStartup
public void setAutoStartup(BooleanSE autoStartup)
- パラメーター:
autoStartup
- 自動起動の場合は true。- 関連事項:
AbstractMessageListenerContainer.setAutoStartup(boolean)
setPhase
public void setPhase(int phase)
- パラメーター:
phase
- フェーズ。- 関連事項:
AbstractMessageListenerContainer.setPhase(int)
setAfterReceivePostProcessors
public void setAfterReceivePostProcessors(MessagePostProcessor... postProcessors)
メッセージの受信後に適用されるポストプロセッサーを設定します。- パラメーター:
postProcessors
- ポストプロセッサー。- 導入:
- 2.0
- 関連事項:
AbstractMessageListenerContainer.setAfterReceivePostProcessors(MessagePostProcessor...)
setContainerCustomizer
public void setContainerCustomizer(ContainerCustomizer<C> containerCustomizer)
コンテナーの作成および構成後に呼び出されるContainerCustomizer
を設定して、コンテナーをさらにカスタマイズできるようにします。- パラメーター:
containerCustomizer
- カスタマイザー。- 導入:
- 2.2.2
setBatchListener
public void setBatchListener(boolean isBatch)
BatchingRabbitTemplate
によって作成された、デバッチされたメッセージのリストを受け取るには、true に設定します。- パラメーター:
isBatch
- バッチリスナーの場合は true。- 導入:
- 2.2
- 関連事項:
setBatchingStrategy(BatchingStrategy)
setBatchingStrategy
public void setBatchingStrategy(BatchingStrategy batchingStrategy)
メッセージのデバッチ時に使用するBatchingStrategy
を設定します。- パラメーター:
batchingStrategy
- バッチ戦略。- 導入:
- 2.2
- 関連事項:
setBatchListener(boolean)
setDeBatchingEnabled
public void setDeBatchingEnabled(BooleanSE deBatchingEnabled)
コンテナーがバッチ処理されたメッセージのバッチ処理を解除するか(true)、バッチを使用してリスナーを呼び出すか(false)を決定します。デフォルト: true。- パラメーター:
deBatchingEnabled
- メッセージのデバッチを無効にするかどうか。- 導入:
- 2.2
- 関連事項:
AbstractMessageListenerContainer.setDeBatchingEnabled(boolean)
setGlobalQos
public void setGlobalQos(boolean globalQos)
チャネル全体にプリフェッチを適用します。- パラメーター:
globalQos
- チャネル全体のプリフェッチの場合は true。- 導入:
- 2.2.17
- 関連事項:
Channel.basicQos(int, boolean)
createListenerContainer
public C createListenerContainer(RabbitListenerEndpoint endpoint)
インターフェースからコピーされた説明:RabbitListenerContainerFactory
指定されたRabbitListenerEndpoint
のMessageListenerContainer
を作成します。- 次で指定:
- インターフェース
RabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>
のcreateListenerContainer
- 次で指定:
- クラス
BaseRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>
のcreateListenerContainer
- パラメーター:
endpoint
- 構成するエンドポイント。- 戻り値:
- 作成したコンテナー。
createContainerInstance
protected abstract C createContainerInstance()
空のコンテナーインスタンスを作成します。- 戻り値:
- 新しいコンテナーインスタンス。
initializeContainer
protected void initializeContainer(C instance, RabbitListenerEndpoint endpoint)
さらに、指定されたコンテナーを初期化します。サブクラスはこのメソッドを継承して、必要に応じて追加の構成を適用できます。
- パラメーター:
instance
- 構成するコンテナーインスタンス。endpoint
- エンドポイント。