Uses of Class
org.springframework.data.redis.connection.stream.StreamInfo.XInfoConsumer
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 StreamInfo.XInfoConsumer in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptiondefault reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>
ReactiveStreamCommands.xInfoConsumers
(ByteBuffer key, String groupName) Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,
reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>> ReactiveStreamCommands.xInfoConsumers
(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands) Obtain information about every consumer in a specific consumer group for the stream stored at the specified key. -
Uses of StreamInfo.XInfoConsumer in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionStreamInfo.XInfoConsumers.get
(int index) Returns theStreamInfo.XInfoConsumer
element at the given index.Modifier and TypeMethodDescriptionStreamInfo.XInfoConsumers.iterator()
Returns an iterator over theStreamInfo.XInfoConsumer
elements.StreamInfo.XInfoConsumers.stream()
Returns a sequentialStream
ofStreamInfo.XInfoConsumer
.Modifier and TypeMethodDescriptionvoid
StreamInfo.XInfoConsumers.forEach
(Consumer<? super StreamInfo.XInfoConsumer> action) Performs the given action on every availableStreamInfo.XInfoConsumer
of thisStreamInfo.XInfoConsumers
. -
Uses of StreamInfo.XInfoConsumer in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<StreamInfo.XInfoConsumer>
Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.