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

Packages that use Consumer

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.
org.springframework.data.redis.stream

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

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

Modifier and Type	Method	Description
@Nullable Consumer	ReactiveStreamCommands.ReadCommand.getConsumer()

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

Modifier and Type	Method	Description
ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.as(Consumer consumer)	Applies a Consumer.
static ReactiveStreamCommands.GroupCommand	ReactiveStreamCommands.GroupCommand.deleteConsumer(Consumer consumer)
default Boolean	DefaultedRedisConnection.xGroupDelConsumer(byte[] key, Consumer consumer)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
Boolean	DefaultStringRedisConnection.xGroupDelConsumer(byte[] key, Consumer consumer)
Boolean	DefaultStringRedisConnection.xGroupDelConsumer(String key, Consumer consumer)
default Mono<String>	ReactiveStreamCommands.xGroupDelConsumer(ByteBuffer key, Consumer consumer)	Delete a consumer from a consumer group.
Boolean	RedisStreamCommands.xGroupDelConsumer(byte @NonNull [] key, @NonNull Consumer consumer)	Delete a consumer from a consumer group.
Boolean	StringRedisConnection.xGroupDelConsumer(@NonNull String key, @NonNull Consumer consumer)	Delete a consumer from a consumer group.
default Mono<PendingMessages>	ReactiveStreamCommands.xPending(ByteBuffer key, Consumer consumer)	Obtained detailed information about all pending messages for a given Consumer.
default Mono<PendingMessages>	ReactiveStreamCommands.xPending(ByteBuffer key, Consumer consumer, Range<?> range, Long count)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group.
default Mono<PendingMessages>	ReactiveStreamCommands.xPending(ByteBuffer key, Consumer consumer, Range<?> range, Long count, Duration minIdleTime)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group and over a given Duration of idle time.
default PendingMessages	RedisStreamCommands.xPending(byte[] key, Consumer consumer, Range<?> range, Long count, Duration minIdleTime)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group and over a given Duration of idle time.
default PendingMessages	RedisStreamCommands.xPending(byte @NonNull [] key, @NonNull Consumer consumer)	Obtained detailed information about all pending messages for a given Consumer.
default PendingMessages	RedisStreamCommands.xPending(byte @NonNull [] key, @NonNull Consumer consumer, @NonNull Range<?> range, @NonNull Long count)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group.
default PendingMessages	StringRedisConnection.xPending(@NonNull String key, @NonNull Consumer consumer, @NonNull Range<String> range, @NonNull Long count)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group.
default PendingMessages	StringRedisConnection.xPending(@NonNull String key, @NonNull Consumer consumer, @NonNull Range<String> range, @NonNull Long count, @NonNull Duration minIdleTime)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group and over a given Duration of idle time.
default List<ByteRecord>	DefaultedRedisConnection.xReadGroup(Consumer consumer, StreamOffset<byte[]>... streams)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
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, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
default Flux<ByteBufferRecord>	ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
default List<@NonNull ByteRecord>	RedisStreamCommands.xReadGroup(@NonNull Consumer consumer, @NonNull StreamOffset<byte[]> @NonNull ... 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 StreamOffset<String> stream)	Read records from one or more StreamOffsets using a consumer group.
default List<StringRecord>	StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamOffset<String> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.
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 Consumer

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

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

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

Modifier and Type	Method	Description
static Consumer	Consumer.from(String group, String name)	Create a new consumer.
Consumer	PendingMessage.getConsumer()	The Consumer to acknowledge the message.

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

Modifier	Constructor	Description
	PendingMessage(RecordId id, Consumer consumer, Duration elapsedTimeSinceLastDelivery, long totalDeliveryCount)

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

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

Modifier and Type	Method	Description
Boolean	BoundStreamOperations.deleteConsumer(@NonNull Consumer consumer)	Delete a consumer from a consumer group.
Mono<String>	ReactiveStreamOperations.deleteConsumer(@NonNull K key, @NonNull Consumer consumer)	Delete a consumer from a consumer group.
Boolean	StreamOperations.deleteConsumer(@NonNull K key, @NonNull Consumer consumer)	Delete a consumer from a consumer group.
default Mono<PendingMessages>	ReactiveStreamOperations.pending(@NonNull K key, @NonNull Consumer consumer)	Obtained detailed information about all pending messages for a given Consumer.
Mono<PendingMessages>	ReactiveStreamOperations.pending(@NonNull K key, @NonNull Consumer consumer, @NonNull Range<?> range, long count)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group.
default PendingMessages	StreamOperations.pending(@NonNull K key, @NonNull Consumer consumer)	Obtained detailed information about all pending messages for a given Consumer.
PendingMessages	StreamOperations.pending(@NonNull K key, @NonNull Consumer consumer, @NonNull Range<?> range, long count)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group.
PendingMessages	StreamOperations.pending(@NonNull K key, @NonNull Consumer consumer, @NonNull Range<?> range, long count, @NonNull Duration minIdleTime)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group and over a given Duration of idle time.
default List<@NonNull MapRecord<K,HK,HV>>	BoundStreamOperations.read(@NonNull Consumer consumer, @NonNull ReadOffset readOffset)	Read records starting from ReadOffset. using a consumer group.
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.
default <V> Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, @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 Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamOffset<K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.
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.
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<ObjectRecord<K,V>>	StreamOperations.read(@NonNull Class<V> targetType, @NonNull Consumer consumer, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group 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.
default List<@NonNull MapRecord<K,HK,HV>>	StreamOperations.read(@NonNull Consumer consumer, StreamOffset<@NonNull K> @NonNull ... streams)	Read records from one or more StreamOffsets using a consumer group.

Uses of Consumer in org.springframework.data.redis.stream

Methods in org.springframework.data.redis.stream that return Consumer

Modifier and Type	Method	Description
Consumer	StreamMessageListenerContainer.ConsumerStreamReadRequest.getConsumer()

Methods in org.springframework.data.redis.stream with parameters of type Consumer

Modifier and Type	Method	Description
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K>	StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.consumer(Consumer consumer)	Configure a Consumer to consume stream messages within a consumer group.
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K>	StreamMessageListenerContainer.StreamReadRequestBuilder.consumer(Consumer consumer)	Configure a Consumer to consume stream messages within a consumer group.
default Subscription	StreamMessageListenerContainer.receive(Consumer consumer, StreamOffset<K> streamOffset, StreamListener<K,V> listener)	Register a new subscription for a Redis Stream.
Flux<V>	StreamReceiver.receive(Consumer consumer, StreamOffset<K> streamOffset)	Starts a Redis Stream consumer that consumes records from the stream.
default Subscription	StreamMessageListenerContainer.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset, StreamListener<K,V> listener)	Register a new subscription for a Redis Stream.
Flux<V>	StreamReceiver.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset)	Starts a Redis Stream consumer that consumes records from the stream.