クラスの使用
org.springframework.data.redis.connection.stream.StreamReadOptions
StreamReadOptions を使用するパッケージ
パッケージ
説明
さまざまな Redis ' ドライバー '/libraries と対話するための低レベルの抽象化を提供する接続パッケージ。
Redis ストリームと対話するためのデータ構造とインターフェース。
Redis を Spring の概念と統合するためのコアパッケージ。
org.springframework.data.redis.connection 内の StreamReadOptions 使用
型 StreamReadOptions のパラメーターを持つ org.springframework.data.redis.connection のメソッド修飾子と型メソッド説明ReactiveStreamCommands.ReadCommand.withOptions(StreamReadOptions options) 指定されたStreamReadOptionsを適用します。default ListSE<ByteRecord>DefaultedRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) 使用すべきではありません。DefaultStringRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default reactor.core.publisher.Flux<ByteBufferRecord>ReactiveStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。RedisStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<StringSE>... streams) default ListSE<StringRecord>StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<StringSE> stream) 1 つ以上のStreamOffsetからレコードを読み取ります。StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<StringSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<ByteRecord>DefaultedRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) 使用すべきではありません。DefaultStringRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default reactor.core.publisher.Flux<ByteBufferRecord>ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。RedisStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<StringSE>... streams) default ListSE<StringRecord>StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<StringSE> stream) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<StringSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。型 StreamReadOptions のパラメーターを持つ org.springframework.data.redis.connection のコンストラクター修飾子コンストラクター説明ReadCommand(ListSE<StreamOffset<ByteBufferSE>> streamOffsets, StreamReadOptions readOptions, Consumer consumer) org.springframework.data.redis.connection.stream 内の StreamReadOptions 使用
修飾子と型メソッド説明StreamReadOptions.autoAcknowledge()コンシューマーグループのコンテキストで読み取るときにNOACKフラグを設定して、自動確認応答を有効にします。StreamReadOptions.block(DurationSE timeout) ブロッキング読み取りを使用してtimeoutSE を指定すると、メッセージが読み取られなかった場合に呼び出しが終了します。StreamReadOptions.count(long count) ストリームごとに返されるメッセージの数を制限します。static StreamReadOptionsStreamReadOptions.empty()空のStreamReadOptionsインスタンスを作成します。StreamReadOptions.noack()コンシューマーグループのコンテキストで読み取るときにNOACKフラグを設定して、自動確認応答を有効にします。org.springframework.data.redis.core 内の StreamReadOptions 使用
型 StreamReadOptions のパラメーターを持つ org.springframework.data.redis.core のメソッド修飾子と型メソッド説明BoundStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, ReadOffset readOffset) ReadOffsetから始まるレコードを読み取ります。コンシューマーグループを使用します。BoundStreamOperations.read(StreamReadOptions readOptions, ReadOffset readOffset) ReadOffsetから始まるレコードを読み取ります。default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> ReactiveStreamOperations.read(ClassSE<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> ReactiveStreamOperations.read(ClassSE<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。ReactiveStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。ReactiveStreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<ObjectRecord<K,V>> StreamOperations.read(ClassSE<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<ObjectRecord<K,V>> StreamOperations.read(ClassSE<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。StreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。
RedisCommandsProvider.streamCommands()を推奨。