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

クラス 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

  • コンストラクターの概要

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

  • メソッドのサマリー

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

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