Uses of Class
org.springframework.data.redis.connection.stream.PendingMessages
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 PendingMessages in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptiondefault PendingMessages
DefaultedRedisConnection.xPending
(byte[] key, String groupName, RedisStreamCommands.XPendingOptions options) Deprecated.DefaultStringRedisConnection.xPending
(byte[] key, String groupName, RedisStreamCommands.XPendingOptions options) DefaultStringRedisConnection.xPending
(String key, String groupName, String consumer, org.springframework.data.domain.Range<String> range, Long count) DefaultStringRedisConnection.xPending
(String key, String groupName, org.springframework.data.domain.Range<String> range, Long count) DefaultStringRedisConnection.xPending
(String key, String groupName, RedisStreamCommands.XPendingOptions options) default PendingMessages
Obtained detailed information about all pending messages for a given consumer.default PendingMessages
RedisStreamCommands.xPending
(byte[] key, String groupName, String consumerName, org.springframework.data.domain.Range<?> range, Long count) Obtain detailed information about pendingmessages
for a givenRange
and consumer within a consumer group.default PendingMessages
RedisStreamCommands.xPending
(byte[] key, String groupName, org.springframework.data.domain.Range<?> range, Long count) Obtain detailed information about pendingmessages
for a givenRange
within a consumer group.RedisStreamCommands.xPending
(byte[] key, String groupName, RedisStreamCommands.XPendingOptions options) 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) StringRedisConnection.xPending
(String key, String groupName, String consumerName, org.springframework.data.domain.Range<String> range, Long count) Obtain detailed information about pendingmessages
for a givenRange
within a consumer group.StringRedisConnection.xPending
(String key, String groupName, org.springframework.data.domain.Range<String> range, Long count) Obtain detailed information about pendingmessages
for a givenRange
within a consumer group.StringRedisConnection.xPending
(String key, String groupName, RedisStreamCommands.XPendingOptions options) Modifier and TypeMethodDescriptiondefault 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, org.springframework.data.domain.Range<?> range, Long count) Obtain detailed information about pendingmessages
for a givenRange
and consumer within a consumer group.default reactor.core.publisher.Mono<PendingMessages>
ReactiveStreamCommands.xPending
(ByteBuffer key, String groupName, org.springframework.data.domain.Range<?> range, Long count) Obtain detailed information about pendingmessages
for a givenRange
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 givenConsumer
.default reactor.core.publisher.Mono<PendingMessages>
ReactiveStreamCommands.xPending
(ByteBuffer key, Consumer consumer, org.springframework.data.domain.Range<?> range, Long count) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,
PendingMessages>> ReactiveStreamCommands.xPending
(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands) -
Uses of PendingMessages in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionPendingMessages.withinRange
(org.springframework.data.domain.Range<?> range) Adds the range to the currentPendingMessages
. -
Uses of PendingMessages in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionStreamOperations.pending
(K key, String group, org.springframework.data.domain.Range<?> range, long count) Obtain detailed information about pendingmessages
for a givenRange
within a consumer group.default PendingMessages
Obtained detailed information about all pending messages for a givenConsumer
.Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<PendingMessages>
ReactiveStreamOperations.pending
(K key, String group, org.springframework.data.domain.Range<?> range, long count) Obtain detailed information about pendingmessages
for a givenRange
within a consumer group.default reactor.core.publisher.Mono<PendingMessages>
Obtained detailed information about all pending messages for a givenConsumer
.reactor.core.publisher.Mono<PendingMessages>
RedisCommandsProvider.streamCommands()
}.