パッケージ org.springframework.integration.aggregator

クラス TimeoutCountSequenceSizeReleaseStrategy

java.lang.ObjectSE
org.springframework.integration.aggregator.TimeoutCountSequenceSizeReleaseStrategy
実装されたすべてのインターフェース:
ReleaseStrategy
public class TimeoutCountSequenceSizeReleaseStrategy extends ObjectSE implements ReleaseStrategy
次のいずれかに該当する場合にすべてのメッセージを解放する ReleaseStrategy:
  • シーケンスが完了しました（ある場合）。
  • ユーザーが設定したしきい値を超えるメッセージがあります。
  • タイムスタンプ（存在する場合）に応じて、最初のメッセージから経過した時間が、ユーザーが設定したタイムアウトを超えています。
導入:
2.0
作成者:
Dave Syer, Gary Russell, Peter Uhlenbruck

  • フィールドの詳細

    • DEFAULT_TIMEOUT

      public static final long DEFAULT_TIMEOUT
      デフォルトのタイムアウトは 1 分です。
      関連事項:

    • DEFAULT_THRESHOLD

      public static final int DEFAULT_THRESHOLD
      デフォルトのしきい値は事実上無限です。
      関連事項:

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

    • TimeoutCountSequenceSizeReleaseStrategy

      public TimeoutCountSequenceSizeReleaseStrategy()

    • TimeoutCountSequenceSizeReleaseStrategy

      public TimeoutCountSequenceSizeReleaseStrategy(int threshold, long timeout)
      パラメーター:
      threshold - リリースする前に受け入れるメッセージの数
      timeout - リリースのタイムアウト（ミリ秒単位）

  • メソッドの詳細