Uses of Class
org.springframework.data.redis.connection.stream.Consumer
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Data structures and interfaces to interact with Redis Streams.
Core package for integrating Redis with Spring concepts.
-
Uses of Consumer in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionApplies aConsumer
.ReactiveStreamCommands.GroupCommand.deleteConsumer
(Consumer consumer) default Boolean
DefaultedRedisConnection.xGroupDelConsumer
(byte[] key, Consumer consumer) Deprecated.DefaultStringRedisConnection.xGroupDelConsumer
(byte[] key, Consumer consumer) DefaultStringRedisConnection.xGroupDelConsumer
(String key, Consumer consumer) default reactor.core.publisher.Mono<String>
ReactiveStreamCommands.xGroupDelConsumer
(ByteBuffer key, Consumer consumer) Delete a consumer from a consumer group.RedisStreamCommands.xGroupDelConsumer
(byte[] key, Consumer consumer) Delete a consumer from a consumer group.StringRedisConnection.xGroupDelConsumer
(String key, Consumer consumer) Delete a consumer from a consumer group.default reactor.core.publisher.Mono<PendingMessages>
ReactiveStreamCommands.xPending
(ByteBuffer key, Consumer consumer) Obtained detailed information about all pending messages for a givenConsumer
.default reactor.core.publisher.Mono<PendingMessages>
ReactiveStreamCommands.xPending
(ByteBuffer key, Consumer consumer, org.springframework.data.domain.Range<?> range, Long count) default PendingMessages
Obtained detailed information about all pending messages for a givenConsumer
.default PendingMessages
RedisStreamCommands.xPending
(byte[] key, Consumer consumer, org.springframework.data.domain.Range<?> range, Long count) default List<ByteRecord>
DefaultedRedisConnection.xReadGroup
(Consumer consumer, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default List<ByteRecord>
DefaultedRedisConnection.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.DefaultStringRedisConnection.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xReadGroup
(Consumer consumer, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s using a consumer group.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or moreStreamOffset
s using a consumer group.default List<ByteRecord>
RedisStreamCommands.xReadGroup
(Consumer consumer, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s using a consumer group.RedisStreamCommands.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s using a consumer group.DefaultStringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamOffset<String> stream) Read records from one or moreStreamOffset
s using a consumer group.default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s using a consumer group.default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or moreStreamOffset
s using a consumer group.StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s using a consumer group.ModifierConstructorDescriptionReadCommand
(List<StreamOffset<ByteBuffer>> streamOffsets, StreamReadOptions readOptions, Consumer consumer) -
Uses of Consumer in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionstatic Consumer
Create a new consumer.PendingMessage.getConsumer()
TheConsumer
to acknowledge the message.ModifierConstructorDescriptionPendingMessage
(RecordId id, Consumer consumer, Duration elapsedTimeSinceLastDelivery, long totalDeliveryCount) -
Uses of Consumer in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionBoundStreamOperations.deleteConsumer
(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.StreamOperations.deleteConsumer
(K key, Consumer consumer) Delete a consumer from a consumer group.default reactor.core.publisher.Mono<PendingMessages>
Obtained detailed information about all pending messages for a givenConsumer
.reactor.core.publisher.Mono<PendingMessages>
ReactiveStreamOperations.pending
(K key, Consumer consumer, org.springframework.data.domain.Range<?> range, long count) default PendingMessages
Obtained detailed information about all pending messages for a givenConsumer
.StreamOperations.pending
(K key, Consumer consumer, org.springframework.data.domain.Range<?> range, long count) BoundStreamOperations.read
(Consumer consumer, ReadOffset readOffset) Read records starting fromReadOffset
. using a consumer group.BoundStreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, ReadOffset readOffset) Read records starting fromReadOffset
. using a consumer group.default <V> reactor.core.publisher.Flux<ObjectRecord<K,
V>> ReactiveStreamOperations.read
(Class<V> targetType, Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group asObjectRecord
.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 moreStreamOffset
s using a consumer group asObjectRecord
.ReactiveStreamOperations.read
(Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.ReactiveStreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s 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 moreStreamOffset
s using a consumer group asObjectRecord
.default <V> List<ObjectRecord<K,
V>> StreamOperations.read
(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group asObjectRecord
.StreamOperations.read
(Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.StreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group. -
Uses of Consumer in org.springframework.data.redis.stream
Modifier and TypeMethodDescriptionStreamMessageListenerContainer.ConsumerStreamReadRequest.getConsumer()
Modifier and TypeMethodDescriptionConfigure aConsumer
to consume stream messages within a consumer group.Configure aConsumer
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.reactor.core.publisher.Flux<V>
StreamReceiver.receive
(Consumer consumer, StreamOffset<K> streamOffset) default Subscription
StreamMessageListenerContainer.receiveAutoAck
(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)
RedisCommandsProvider.streamCommands()
}.