クラス SimpleRabbitListenerContainerFactory

メソッドの詳細

• setBatchSize

  public void setBatchSize(IntegerSE batchSize)

  パラメーター:

  batchSize - バッチサイズ。

  導入:

  2.2

  関連事項:

  • SimpleMessageListenerContainer.setBatchSize(int)

• setConcurrentConsumers

  public void setConcurrentConsumers(IntegerSE concurrency)

  パラメーター:

  concurrency - 作成するコンシューマーの最小数。

  関連事項:

  • SimpleMessageListenerContainer.setConcurrentConsumers(int)

• setMaxConcurrentConsumers

  public void setMaxConcurrentConsumers(IntegerSE maxConcurrency)

  パラメーター:

  maxConcurrency - コンシューマーの最大数。

  関連事項:

  • SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)

• setStartConsumerMinInterval

  public void setStartConsumerMinInterval(LongSE minStartInterval)

  パラメーター:

  minStartInterval - 新しいコンシューマーが起動する最小間隔。

  関連事項:

  • SimpleMessageListenerContainer.setStartConsumerMinInterval(long)

• setStopConsumerMinInterval

  public void setStopConsumerMinInterval(LongSE minStopInterval)

  パラメーター:

  minStopInterval - コンシューマーが停止する最小間隔。

  関連事項:

  • SimpleMessageListenerContainer.setStopConsumerMinInterval(long)

• setConsecutiveActiveTrigger

  public void setConsecutiveActiveTrigger(IntegerSE minConsecutiveActive)

  パラメーター:

  minConsecutiveActive - 新しいコンシューマーをトリガーする連続受信の数。

  関連事項:

  • SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)

• setConsecutiveIdleTrigger

  public void setConsecutiveIdleTrigger(IntegerSE minConsecutiveIdle)

  パラメーター:

  minConsecutiveIdle - コンシューマーの停止をトリガーする連続タイムアウトの数。

  関連事項:

  • SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)

• setReceiveTimeout

  public void setReceiveTimeout(LongSE receiveTimeout)

  パラメーター:

  receiveTimeout - タイムアウト。

  関連事項:

  • SimpleMessageListenerContainer.setReceiveTimeout(long)

• setBatchReceiveTimeout

  public void setBatchReceiveTimeout(LongSE batchReceiveTimeout)

  バッチメッセージを収集するためのタイムアウトのミリ秒数。これにより、batchSize がいっぱいになるまでの待ち時間が制限されます。デフォルトは 0 (タイムアウトなし) です。

  パラメーター:

  batchReceiveTimeout - バッチメッセージを収集するためのタイムアウト。

  導入:

  3.1.2

  関連事項:

  • SimpleMessageListenerContainer.setBatchReceiveTimeout(long)
  • setBatchSize(Integer)

• setConsumerBatchEnabled

  public void setConsumerBatchEnabled(boolean consumerBatchEnabled)

  リスナーがサポートしている場合、setBatchSize(Integer) に基づいてメッセージのリストを表示するには、true に設定します。バージョン 3.0 以降、これを true に設定すると、AbstractRabbitListenerContainerFactory.setBatchListener(boolean) も true になります。

  パラメーター:

  consumerBatchEnabled - コンテナーにメッセージバッチを作成する場合は true。

  導入:

  2.2

  関連事項:

  • setBatchSize(Integer)
  • AbstractRabbitListenerContainerFactory.setBatchListener(boolean)

• setEnforceImmediateAckForManual

  public void setEnforceImmediateAckForManual(BooleanSE enforceImmediateAckForManual)

  ImmediateAcknowledgeAmqpException がスローされたときに AcknowledgeMode.MANUAL に対して Channel.basicAck(long, boolean) を強制するには、true に設定します。これは、現在のマイナーバージョンの動作を壊さないための暫定的な解決策である可能性があります。

  パラメーター:

  enforceImmediateAckForManual - ImmediateAcknowledgeAmqpException の MANUAL モードのメッセージを確認するためのフラグ

  導入:

  3.1.2

• createContainerInstance

  protected SimpleMessageListenerContainer createContainerInstance()

  クラスからコピーされた説明: AbstractRabbitListenerContainerFactory

  空のコンテナーインスタンスを作成します。

  次で指定:

  クラス AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer> の createContainerInstance 

  戻り値:

  新しいコンテナーインスタンス。

• initializeContainer

  protected void initializeContainer(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint)

  クラスからコピーされた説明: AbstractRabbitListenerContainerFactory

  さらに、指定されたコンテナーを初期化します。

  サブクラスはこのメソッドを継承して、必要に応じて追加の構成を適用できます。

  オーバーライド:

  クラス AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer> の initializeContainer 

  パラメーター:

  instance - 構成するコンテナーインスタンス。

  endpoint - エンドポイント。