パッケージ org.springframework.amqp.rabbit.config

クラス DirectRabbitListenerContainerFactory

java.lang.ObjectSE
org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<C>
org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory<DirectMessageListenerContainer>
org.springframework.amqp.rabbit.config.DirectRabbitListenerContainerFactory
実装されたすべてのインターフェース:
RabbitListenerContainerFactory<DirectMessageListenerContainer>、Aware、ApplicationContextAware、ApplicationEventPublisherAware
public class DirectRabbitListenerContainerFactory extends AbstractRabbitListenerContainerFactory<DirectMessageListenerContainer>
通常の DirectMessageListenerContainer を構築するための RabbitListenerContainerFactory 実装。
導入:
2.0
作成者:
Gary Russell, Sud Ramasamy

  • コンストラクターの詳細

    • DirectRabbitListenerContainerFactory

      public DirectRabbitListenerContainerFactory()

  • メソッドの詳細

    • setTaskScheduler

      public void setTaskScheduler(TaskScheduler taskScheduler)
      アイドル状態のコンテナーと失敗したコンシューマーを監視するタスクに使用するタスクスケジューラーを設定します。
      パラメーター:
      taskScheduler - スケジューラー。

    • setMonitorInterval

      public void setMonitorInterval(long monitorInterval)
      失敗したコンシューマーとアイドル状態のコンテナーをチェックするタスクを実行する頻度を設定します。
      パラメーター:
      monitorInterval - 間隔 ; デフォルトは 10000 ですが、idleEventInterval/2 (構成されている場合) または failedDeclarationRetryInterval の最小値に調整されます。

    • setConsumersPerQueue

      public void setConsumersPerQueue(IntegerSE consumersPerQueue)
      各キューは独自のコンシューマーで実行されます。このプロパティを設定して、キューごとに複数のコンシューマーを作成します。コンテナーがすでに実行されている場合、キューごとのコンシューマーの数は必要に応じて増減されます。
      パラメーター:
      consumersPerQueue - キューごとのコンシューマー。

    • setMessagesPerAck

      public void setMessagesPerAck(IntegerSE messagesPerAck)
      確認応答 (成功) する前に受信するメッセージの数を設定します。失敗したメッセージは、このカウンターを短絡します。
      パラメーター:
      messagesPerAck - メッセージの数。
      関連事項:

    • setAckTimeout

      public void setAckTimeout(LongSE ackTimeout)
      おおよそのタイムアウト。messagesPerAck が 1 よりも大きく、最後の ACK から時間が経過した場合、保留中の ACK は、次のメッセージが到着したとき、または追加のメッセージが到着しない場合はしばらくしてから送信されます。その場合、実際の時間は monitorInterval によって異なります。
      パラメーター:
      ackTimeout - ミリ秒単位のタイムアウト (デフォルトは 20000)。
      関連事項:

    • createContainerInstance

      protected DirectMessageListenerContainer createContainerInstance()
      クラスからコピーされた説明: AbstractRabbitListenerContainerFactory
      空のコンテナーインスタンスを作成します。
      次で指定:
      クラス AbstractRabbitListenerContainerFactory<DirectMessageListenerContainer> の createContainerInstance 
      戻り値:
      新しいコンテナーインスタンス。

    • initializeContainer

      protected void initializeContainer(DirectMessageListenerContainer instance, RabbitListenerEndpoint endpoint)
      クラスからコピーされた説明: AbstractRabbitListenerContainerFactory
      さらに、指定されたコンテナーを初期化します。

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

      オーバーライド:
      クラス AbstractRabbitListenerContainerFactory<DirectMessageListenerContainer> の initializeContainer 
      パラメーター:
      instance - 構成するコンテナーインスタンス。
      endpoint - エンドポイント。