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
@Nullable 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<@NonNull ByteRecord>	RedisStreamCommands.xRead(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull ... streams)	Read records from one or more StreamOffsets.
List<StringRecord>	DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String>... streams)
default List<StringRecord>	StringRedisConnection.xReadAsString(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<String> stream)	Read records from one or more StreamOffsets.
List<StringRecord>	StringRedisConnection.xReadAsString(@NonNull StreamReadOptions readOptions, @NonNull 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<@NonNull ByteRecord>	RedisStreamCommands.xReadGroup(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull ... 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(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<String> stream)	Read records from one or more StreamOffsets using a consumer group.
List<StringRecord>	StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<String> @NonNull ... 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, @Nullable StreamReadOptions readOptions, @Nullable 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<@NonNull MapRecord<K,HK,HV>>	BoundStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull ReadOffset readOffset)	Read records starting from ReadOffset. using a consumer group.
List<@NonNull MapRecord<K,HK,HV>>	BoundStreamOperations.read(@NonNull StreamReadOptions readOptions, @NonNull ReadOffset readOffset)	Read records starting from ReadOffset.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets as ObjectRecord.
Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K>... streams)	Read records from one or more StreamOffsets using a consumer group.
Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<@NonNull ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets as ObjectRecord.
List<@NonNull MapRecord<K,HK,HV>>	StreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.
List<@NonNull MapRecord<K,HK,HV>>	StreamOperations.read(@NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets.