クラス StreamReadOptions
java.lang.ObjectSE
org.springframework.data.redis.connection.stream.StreamReadOptions
Redis ストリームからメッセージを読み取るためのオプション。
- 作成者:
- Mark Paluch, Christoph Strobl, Kaizhou Zhang
メソッドのサマリー
修飾子と型メソッド説明コンシューマーグループのコンテキストで読み取るときにNOACK
フラグを設定して、自動確認応答を有効にします。block
(DurationSE timeout) ブロッキング読み取りを使用してtimeout
SE を指定すると、メッセージが読み取られなかった場合に呼び出しが終了します。count
(long count) ストリームごとに返されるメッセージの数を制限します。static StreamReadOptions
empty()
空のStreamReadOptions
インスタンスを作成します。boolean
getBlock()
getCount()
int
hashCode()
boolean
boolean
isNoack()
noack()
コンシューマーグループのコンテキストで読み取るときにNOACK
フラグを設定して、自動確認応答を有効にします。toString()
メソッドの詳細
empty
空のStreamReadOptions
インスタンスを作成します。- 戻り値:
- 空の
StreamReadOptions
インスタンス。
noack
コンシューマーグループのコンテキストで読み取るときにNOACK
フラグを設定して、自動確認応答を有効にします。このメソッドは、読みやすさの理由からautoAcknowledge()
のエイリアスです。- 戻り値:
noack
が適用されたStreamReadOptions
。
autoAcknowledge
コンシューマーグループのコンテキストで読み取るときにNOACK
フラグを設定して、自動確認応答を有効にします。このメソッドは、読みやすさの理由からnoack()
のエイリアスです。- 戻り値:
noack
が適用されたStreamReadOptions
の新しいインスタンス。- 導入:
- 2.3
block
ブロッキング読み取りを使用してtimeout
SE を指定すると、メッセージが読み取られなかった場合に呼び出しが終了します。- パラメーター:
timeout
- ブロッキング読み取りのタイムアウトは、null または負であってはなりません。- 戻り値:
block
が適用されたStreamReadOptions
の新しいインスタンス。
count
ストリームごとに返されるメッセージの数を制限します。- パラメーター:
count
- 読み取るメッセージの最大数。- 戻り値:
count
が適用されたStreamReadOptions
。
isBlocking
public boolean isBlocking()- 戻り値:
- 引数が読み取りのブロックを示している場合は true。
- 導入:
- 2.3
getBlock
getCount
isNoack
public boolean isNoack()toString
equals
hashCode
public int hashCode()