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

クラス StreamReadOptions

java.lang.ObjectSE
org.springframework.data.redis.connection.stream.StreamReadOptions
public class StreamReadOptions extends ObjectSE
Redis ストリームからメッセージを読み取るためのオプション。
作成者:
Mark Paluch, Christoph Strobl, Kaizhou Zhang

  • メソッドの詳細

    • empty

      public static StreamReadOptions empty()
      空の StreamReadOptions インスタンスを作成します。
      戻り値:
      空の StreamReadOptions インスタンス。

    • noack

      public StreamReadOptions noack()
      コンシューマーグループのコンテキストで読み取るときに NOACK フラグを設定して、自動確認応答を有効にします。このメソッドは、読みやすさの理由から autoAcknowledge() のエイリアスです。
      戻り値:
      noack が適用された StreamReadOptions。

    • autoAcknowledge

      public StreamReadOptions autoAcknowledge()
      コンシューマーグループのコンテキストで読み取るときに NOACK フラグを設定して、自動確認応答を有効にします。このメソッドは、読みやすさの理由から noack() のエイリアスです。
      戻り値:
      noack が適用された StreamReadOptions の新しいインスタンス。
      導入:
      2.3

    • block

      public StreamReadOptions block(DurationSE timeout)
      ブロッキング読み取りを使用して timeoutSE を指定すると、メッセージが読み取られなかった場合に呼び出しが終了します。
      パラメーター:
      timeout - ブロッキング読み取りのタイムアウトは、null または負であってはなりません。
      戻り値:
      block が適用された StreamReadOptions の新しいインスタンス。

    • count

      public StreamReadOptions count(long count)
      ストリームごとに返されるメッセージの数を制限します。
      パラメーター:
      count - 読み取るメッセージの最大数。
      戻り値:
      count が適用された StreamReadOptions。

    • isBlocking

      public boolean isBlocking()
      戻り値:
      引数が読み取りのブロックを示している場合は true。
      導入:
      2.3

    • getBlock

      @Nullable public LongSE getBlock()

    • getCount

      @Nullable public LongSE getCount()

    • isNoack

      public boolean isNoack()

    • toString

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

    • equals

      public boolean equals(@Nullable ObjectSE o)
      オーバーライド:
      クラス ObjectSE の equalsSE 

    • hashCode

      public int hashCode()
      オーバーライド:
      クラス ObjectSE の hashCode