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 and Description
Consumer	ReactiveStreamCommands.ReadCommand.getConsumer()

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

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

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

Constructor and 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 and 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

Constructor and 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 and Description
Boolean	BoundStreamOperations.deleteConsumer(Consumer consumer) Delete a consumer from a consumer group.
Boolean	StreamOperations.deleteConsumer(K key, Consumer consumer) Delete a consumer from a consumer group.
reactor.core.publisher.Mono<String>	ReactiveStreamOperations.deleteConsumer(K key, Consumer consumer) Delete a consumer from a consumer group.
default PendingMessages	StreamOperations.pending(K key, Consumer consumer) Obtained detailed information about all pending messages for a given Consumer.
default reactor.core.publisher.Mono<PendingMessages>	ReactiveStreamOperations.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.
reactor.core.publisher.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 <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> reactor.core.publisher.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> 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> reactor.core.publisher.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 List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(Consumer consumer, ReadOffset readOffset) Read records starting from ReadOffset. using a consumer group.
default List<MapRecord<K,HK,HV>>	StreamOperations.read(Consumer consumer, StreamOffset<K>... streams) Read records from one or more StreamOffsets using a consumer group.
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(Consumer consumer, StreamOffset<K>... streams) Read records from one or more StreamOffsets 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.
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.
reactor.core.publisher.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.

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

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

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

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

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