クラス AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer>

メソッドの詳細

• 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 - 使用する ExecutorSE。

  関連事項:

  • 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)

• 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 

• 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)

• setMessageAckListener

  public void setMessageAckListener(MessageAckListener messageAckListener)

  AcknowledgeMode.AUTO モードでメッセージ (メッセージ) を確認するときに使用する MessageAckListener を設定します。

  パラメーター:

  messageAckListener - メッセージ AckListener。

  導入:

  2.4.6

• setObservationConvention

  public void setObservationConvention(RabbitListenerObservationConvention observationConvention)

  観察規則を設定します。観測に追加のキー / 値を追加するために使用されます。

  パラメーター:

  observationConvention - 大会。

  導入:

  3.0

• setForceStop

  public void setForceStop(boolean forceStop)

  現在のメッセージが処理された後にコンテナーを停止し、プリフェッチされたメッセージを再度キューに入れるには true に設定します。排他的または単一アクティブなコンシューマーを使用する場合に便利です。

  パラメーター:

  forceStop - 現在のメッセージが処理されたときに停止する場合は true。

  導入:

  2.4.15

• 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 - エンドポイント。