クラスの使用
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 Flux<ByteBufferRecord> ReactiveStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。ListSE<@NonNull ByteRecord> RedisStreamCommands.xRead(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<StringSE>... streams) default ListSE<StringRecord> StringRedisConnection.xReadAsString(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<StringSE> stream) 1 つ以上のStreamOffsetからレコードを読み取ります。StringRedisConnection.xReadAsString(@NonNull StreamReadOptions readOptions, @NonNull 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 Flux<ByteBufferRecord> ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。ListSE<@NonNull ByteRecord> RedisStreamCommands.xReadGroup(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<StringSE>... streams) default ListSE<StringRecord> StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<StringSE> stream) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<StringSE> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。型 StreamReadOptions のパラメーターを持つ org.springframework.data.redis.connection のコンストラクター修飾子コンストラクター説明ReadCommand(ListSE<StreamOffset<ByteBufferSE>> streamOffsets, @Nullable StreamReadOptions readOptions, @Nullable 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(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull ReadOffset readOffset) ReadOffsetから始まるレコードを読み取ります。コンシューマーグループを使用します。BoundStreamOperations.read(@NonNull StreamReadOptions readOptions, @NonNull ReadOffset readOffset) ReadOffsetから始まるレコードを読み取ります。default <V> Flux<ObjectRecord<K, V>> ReactiveStreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> Flux<ObjectRecord<K, V>> ReactiveStreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。ReactiveStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。ReactiveStreamOperations.read(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<ObjectRecord<K, V>> StreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<@NonNull ObjectRecord<K, V>> StreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。StreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StreamOperations.read(@NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。
RedisCommandsProvider.streamCommands()を推奨。