パッケージ org.springframework.data.redis.connection.stream

クラス PendingMessages

java.lang.ObjectSE
org.springframework.data.redis.connection.stream.PendingMessages
実装されたすべてのインターフェース:
IterableSE<PendingMessage>、SupplierSE<StreamSE<PendingMessage>>、Streamable<PendingMessage>
public class PendingMessages extends ObjectSE implements Streamable<PendingMessage>
特定の Range およびオフセットのコンシューマーグループ内の保留中のメッセージに関する詳細情報を保持する値オブジェクト。
導入:
2.3
作成者:
Christoph Strobl

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

  • メソッドの詳細

    • withinRange

      public PendingMessages withinRange(Range<?> range)
      現在の PendingMessages に範囲を追加します。
      パラメーター:
      range - null であってはなりません。
      戻り値:
      PendingMessages の新しいインスタンス。

    • getGroupName

      public StringSE getGroupName()
      コンシューマーグループ名。
      戻り値:
      決して null にはなりません。

    • getRange

      public Range<?> getRange()
      Range 保留中のメッセージがロードされました。
      戻り値:
      決して null にはなりません。

    • isEmpty

      public boolean isEmpty()
      次で指定:
      インターフェース Streamable<PendingMessage> の isEmpty 
      戻り値:
      範囲内で保留中のメッセージがない場合は true。

    • size

      public int size()
      戻り値:
      範囲内の保留中のメッセージの数。

    • get

      public PendingMessage get(int index)
      指定された位置で PendingMessage を取得します。
      パラメーター:
      index -
      戻り値:
      PendingMessage は指定されたインデックスです。
      例外:
      IndexOutOfBoundsExceptionSE - インデックスが範囲外の場合。

    • iterator

      public IteratorSE<PendingMessage> iterator()
      次で指定:
      インターフェース IterableSE<PendingMessage> の iterator 

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString