Uses of Class
org.springframework.data.redis.connection.stream.StreamReadOptions

Packages that use StreamReadOptions

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
org.springframework.data.redis.connection.stream	Data structures and interfaces to interact with Redis Streams.
org.springframework.data.redis.core	Core package for integrating Redis with Spring concepts.

Uses of StreamReadOptions in org.springframework.data.redis.connection

Methods in org.springframework.data.redis.connection that return StreamReadOptions

Modifier and Type	Method	Description
StreamReadOptions	ReactiveStreamCommands.ReadCommand.getReadOptions()

Methods in org.springframework.data.redis.connection with parameters of type StreamReadOptions

Modifier and Type	Method	Description
ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.withOptions(StreamReadOptions options)	Applies the given StreamReadOptions.
default List<ByteRecord>	DefaultedRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
List<ByteRecord>	DefaultStringRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams)
default Flux<ByteBufferRecord>	ReactiveStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets.
List<ByteRecord>	RedisStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams)	Read records from one or more StreamOffsets.
List<StringRecord>	DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String>... streams)
default List<StringRecord>	StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String> stream)	Read records from one or more StreamOffsets.
List<StringRecord>	StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String>... streams)	Read records from one or more StreamOffsets.
default List<ByteRecord>	DefaultedRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
List<ByteRecord>	DefaultStringRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams)
default Flux<ByteBufferRecord>	ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
List<ByteRecord>	RedisStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams)	Read records from one or more StreamOffsets using a consumer group.
List<StringRecord>	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 more StreamOffsets using a consumer group.
List<StringRecord>	StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams)	Read records from one or more StreamOffsets using a consumer group.

Constructors in org.springframework.data.redis.connection with parameters of type StreamReadOptions

Modifier	Constructor	Description
	ReadCommand(List<StreamOffset<ByteBuffer>> streamOffsets, StreamReadOptions readOptions, Consumer consumer)

Uses of StreamReadOptions in org.springframework.data.redis.connection.stream

Methods in org.springframework.data.redis.connection.stream that return StreamReadOptions

Modifier and Type	Method	Description
StreamReadOptions	StreamReadOptions.autoAcknowledge()	Enable auto-acknowledgement by setting the NOACK flag when reading in the context of a consumer group.
StreamReadOptions	StreamReadOptions.block(Duration timeout)	Use a blocking read and supply the timeout after which the call will terminate if no message was read.
StreamReadOptions	StreamReadOptions.count(long count)	Limit the number of messages returned per stream.
static StreamReadOptions	StreamReadOptions.empty()	Creates an empty StreamReadOptions instance.
StreamReadOptions	StreamReadOptions.noack()	Enable auto-acknowledgement by setting the NOACK flag when reading in the context of a consumer group.

Uses of StreamReadOptions in org.springframework.data.redis.core

Methods in org.springframework.data.redis.core with parameters of type StreamReadOptions

Modifier and Type	Method	Description
List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, ReadOffset readOffset)	Read records starting from ReadOffset. using a consumer group.
List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(StreamReadOptions readOptions, ReadOffset readOffset)	Read records starting from ReadOffset.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group.
Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets as ObjectRecord.
List<MapRecord<K,HK,HV>>	StreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group.
List<MapRecord<K,HK,HV>>	StreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams)	Read records from one or more StreamOffsets.