Uses of Class
org.springframework.data.redis.connection.stream.StreamReadOptions
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Data structures and interfaces to interact with Redis Streams.
Core package for integrating Redis with Spring concepts.
-
Uses of StreamReadOptions in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionReactiveStreamCommands.ReadCommand.withOptions
(StreamReadOptions options) Applies the givenStreamReadOptions
.default List<ByteRecord>
DefaultedRedisConnection.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated.DefaultStringRedisConnection.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xRead
(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s.RedisStreamCommands.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s.DefaultStringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String>... streams) default List<StringRecord>
StringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or moreStreamOffset
s.StringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s.default List<ByteRecord>
DefaultedRedisConnection.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.DefaultStringRedisConnection.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s using a consumer group.RedisStreamCommands.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s using a consumer group.DefaultStringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or moreStreamOffset
s using a consumer group.StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s using a consumer group.ModifierConstructorDescriptionReadCommand
(List<StreamOffset<ByteBuffer>> streamOffsets, StreamReadOptions readOptions, Consumer consumer) -
Uses of StreamReadOptions in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionStreamReadOptions.autoAcknowledge()
Enable auto-acknowledgement by setting theNOACK
flag when reading in the context of a consumer group.Use a blocking read and supply thetimeout
after which the call will terminate if no message was read.StreamReadOptions.count
(long count) Limit the number of messages returned per stream.static StreamReadOptions
StreamReadOptions.empty()
Creates an emptyStreamReadOptions
instance.StreamReadOptions.noack()
Enable auto-acknowledgement by setting theNOACK
flag when reading in the context of a consumer group. -
Uses of StreamReadOptions in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionBoundStreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, ReadOffset readOffset) Read records starting fromReadOffset
. using a consumer group.BoundStreamOperations.read
(StreamReadOptions readOptions, ReadOffset readOffset) Read records starting fromReadOffset
.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> ReactiveStreamOperations.read
(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group asObjectRecord
.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> ReactiveStreamOperations.read
(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s asObjectRecord
.ReactiveStreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.ReactiveStreamOperations.read
(StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.default <V> List<ObjectRecord<K,
V>> StreamOperations.read
(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group asObjectRecord
.default <V> List<ObjectRecord<K,
V>> StreamOperations.read
(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s asObjectRecord
.StreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.StreamOperations.read
(StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.
RedisCommandsProvider.streamCommands()
}.