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
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[] key, Consumer consumer)	Delete a consumer from a consumer group.
Boolean	StringRedisConnection.xGroupDelConsumer(String key, 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 PendingMessages	RedisStreamCommands.xPending(byte[] key, Consumer consumer)	Obtained detailed information about all pending messages for a given Consumer.
default PendingMessages	RedisStreamCommands.xPending(byte[] key, Consumer consumer, Range<?> range, Long count)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group.
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<ByteRecord>	RedisStreamCommands.xReadGroup(Consumer consumer, StreamOffset<byte[]>... 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, StreamOffset<String> stream)	Read records from one or more StreamOffsets using a consumer group.
default List<StringRecord>	StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamOffset<String>... streams)	Read records from one or more StreamOffsets using a consumer group.
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 Consumer

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

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.