クラス MessageCountReleaseStrategy

java.lang.ObjectSE
org.springframework.integration.aggregator.MessageCountReleaseStrategy
実装されたすべてのインターフェース:
ReleaseStrategy

public class MessageCountReleaseStrategy extends ObjectSE implements ReleaseStrategy
最初の n メッセージのみを解放する ReleaseStrategy。ここで、n はしきい値です。
作成者:
Dave Syer, Oleg Zhurakousky, Artem Bilan
  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
    便利なコンストラクターは、必要なメッセージが 1 つだけです(threshold = 1)。
    提供されたしきい値に基づいてインスタンスを構築します。
  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    boolean
    しきい値を超えるメッセージがあり、以前に解放されていない場合は、グループを解放します。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
  • コンストラクターの詳細

    • MessageCountReleaseStrategy

      public MessageCountReleaseStrategy()
      便利なコンストラクターは、必要なメッセージが 1 つだけです(threshold = 1)。
    • MessageCountReleaseStrategy

      public MessageCountReleaseStrategy(int threshold)
      提供されたしきい値に基づいてインスタンスを構築します。
      パラメーター:
      threshold - リリースする前に受け入れるメッセージの数
  • メソッドの詳細

    • canRelease

      public boolean canRelease(MessageGroup group)
      しきい値を超えるメッセージがあり、以前に解放されていない場合は、グループを解放します。複数のコンシューマーが同じグループから同時にメッセージを受信した場合に限り、しきい値を超えるメッセージがリリースされる可能性があります。
      次で指定:
      インターフェース ReleaseStrategycanRelease