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

Packages that use PendingMessages

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.

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

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

Modifier and Type	Method	Description
default PendingMessages	DefaultedRedisConnection.xPending(byte[] key, String groupName, RedisStreamCommands.XPendingOptions options)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
PendingMessages	DefaultStringRedisConnection.xPending(byte[] key, String groupName, RedisStreamCommands.XPendingOptions options)
PendingMessages	DefaultStringRedisConnection.xPending(String key, String groupName, String consumer, Range<String> range, Long count)
PendingMessages	DefaultStringRedisConnection.xPending(String key, String groupName, Range<String> range, Long count)
PendingMessages	DefaultStringRedisConnection.xPending(String key, String groupName, RedisStreamCommands.XPendingOptions options)
default PendingMessages	RedisStreamCommands.xPending(byte[] key, String groupName, String consumerName)	Obtained detailed information about all pending messages for a given consumer.
default PendingMessages	RedisStreamCommands.xPending(byte[] key, String groupName, String consumerName, 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, String groupName, Range<?> range, Long count)	Obtain detailed information about pending messages for a given Range within a consumer group.
PendingMessages	RedisStreamCommands.xPending(byte[] key, String groupName, RedisStreamCommands.XPendingOptions options)	Obtain detailed information about pending messages applying given options.
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.
PendingMessages	StringRedisConnection.xPending(String key, String groupName, String consumerName, Range<String> range, Long count)	Obtain detailed information about pending messages for a given Range within a consumer group.
PendingMessages	StringRedisConnection.xPending(String key, String groupName, Range<String> range, Long count)	Obtain detailed information about pending messages for a given Range within a consumer group.
PendingMessages	StringRedisConnection.xPending(String key, String groupName, RedisStreamCommands.XPendingOptions options)	Obtain detailed information about pending messages applying given options.

Methods in org.springframework.data.redis.connection that return types with arguments of type PendingMessages

Modifier and Type	Method	Description
default reactor.core.publisher.Mono<PendingMessages>	ReactiveStreamCommands.xPending(ByteBuffer key, String groupName, String consumerName)	Obtained detailed information about all pending messages for a given consumer.
default reactor.core.publisher.Mono<PendingMessages>	ReactiveStreamCommands.xPending(ByteBuffer key, String groupName, String consumerName, 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, String groupName, Range<?> range, Long count)	Obtain detailed information about pending messages for a given Range 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.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>>	ReactiveStreamCommands.xPending(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)	Obtain detailed information about pending messages applying given options.

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

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

Modifier and Type	Method	Description
PendingMessages	PendingMessages.withinRange(Range<?> range)	Adds the range to the current PendingMessages.

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

Methods in org.springframework.data.redis.core that return PendingMessages

Modifier and Type	Method	Description
PendingMessages	StreamOperations.pending(K key, String group, Range<?> range, long count)	Obtain detailed information about pending messages for a given Range 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.

Methods in org.springframework.data.redis.core that return types with arguments of type PendingMessages

Modifier and Type	Method	Description
reactor.core.publisher.Mono<PendingMessages>	ReactiveStreamOperations.pending(K key, String group, Range<?> range, long count)	Obtain detailed information about pending messages for a given Range within a consumer group.
default reactor.core.publisher.Mono<PendingMessages>	ReactiveStreamOperations.pending(K key, Consumer consumer)	Obtained detailed information about all pending messages for a given Consumer.
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.