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

クラス PendingMessage

java.lang.ObjectSE
org.springframework.data.redis.connection.stream.PendingMessage
public class PendingMessage extends ObjectSE
ID を含む単一の保留中のメッセージ、メッセージをフェッチしてまだ確認する必要のあるコンシューマー、メッセージが最後に配信されてからの経過時間、配信された合計回数を表す値オブジェクト。
導入:
2.3
作成者:
Christoph Strobl

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

    • PendingMessage

      public PendingMessage(RecordId id, Consumer consumer, DurationSE elapsedTimeSinceLastDelivery, long totalDeliveryCount)

  • メソッドの詳細

    • getId

      public RecordId getId()
      戻り値:
      メッセージ ID。

    • getIdAsString

      public StringSE getIdAsString()
      戻り値:
      メッセージ ID は StringSE です。

    • getConsumer

      public Consumer getConsumer()
      メッセージを確認するための Consumer。
      戻り値:
      決して null にはなりません。

    • getConsumerName

      public StringSE getConsumerName()
      メッセージを確認するためのコンシューマー名。
      戻り値:
      決して null にはなりません。

    • getGroupName

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

    • getElapsedTimeSinceLastDelivery

      public DurationSE getElapsedTimeSinceLastDelivery()
      メッセージが consumer に最後に配信されてからの経過時間を（ミリ秒の精度で）取得します。
      戻り値:
      決して null にはなりません。

    • getTotalDeliveryCount

      public long getTotalDeliveryCount()
      メッセージが consumer に配信された合計回数を取得します。
      戻り値:
      決して null にはなりません。

    • toString

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