Uses of Class
io.lettuce.core.models.stream.PendingMessage
-
Packages that use PendingMessage Package Description io.lettuce.core The Redis client package containingRedisClient
for Redis Standalone and Redis Sentinel operations.io.lettuce.core.api.async Standalone Redis API for asynchronous executed commands.io.lettuce.core.api.reactive Standalone Redis API for reactive command execution.io.lettuce.core.api.sync Standalone Redis API for synchronous executed commands.io.lettuce.core.cluster.api.async Redis Cluster API for asynchronous executed commands.io.lettuce.core.cluster.api.sync Redis Cluster API for synchronous executed commands.io.lettuce.core.models.stream Model and parser for the Stream-related command output such as XPENDING.io.lettuce.core.output Implementation of different output protocols including the Streaming API. -
-
Uses of PendingMessage in io.lettuce.core
Methods in io.lettuce.core that return types with arguments of type PendingMessage Modifier and Type Method Description RedisFuture<List<PendingMessage>>
AbstractRedisAsyncCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
RedisFuture<List<PendingMessage>>
AbstractRedisAsyncCommands. xpending(K key, XPendingArgs<K> args)
RedisFuture<List<PendingMessage>>
AbstractRedisAsyncCommands. xpending(K key, K group, Range<String> range, Limit limit)
Flux<PendingMessage>
AbstractRedisReactiveCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Flux<PendingMessage>
AbstractRedisReactiveCommands. xpending(K key, XPendingArgs<K> args)
Flux<PendingMessage>
AbstractRedisReactiveCommands. xpending(K key, K group, Range<String> range, Limit limit)
-
Uses of PendingMessage in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async that return types with arguments of type PendingMessage Modifier and Type Method Description RedisFuture<List<PendingMessage>>
RedisStreamAsyncCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.RedisFuture<List<PendingMessage>>
RedisStreamAsyncCommands. xpending(K key, XPendingArgs<K> args)
Read pending messages from a stream within a specificXPendingArgs
.RedisFuture<List<PendingMessage>>
RedisStreamAsyncCommands. xpending(K key, K group, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
. -
Uses of PendingMessage in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive that return types with arguments of type PendingMessage Modifier and Type Method Description Flux<PendingMessage>
RedisStreamReactiveCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.Flux<PendingMessage>
RedisStreamReactiveCommands. xpending(K key, XPendingArgs<K> args)
Read pending messages from a stream within a specificXPendingArgs
.Flux<PendingMessage>
RedisStreamReactiveCommands. xpending(K key, K group, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
. -
Uses of PendingMessage in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync that return types with arguments of type PendingMessage Modifier and Type Method Description List<PendingMessage>
RedisStreamCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.List<PendingMessage>
RedisStreamCommands. xpending(K key, XPendingArgs<K> args)
Read pending messages from a stream within a specificXPendingArgs
.List<PendingMessage>
RedisStreamCommands. xpending(K key, K group, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
. -
Uses of PendingMessage in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async that return types with arguments of type PendingMessage Modifier and Type Method Description AsyncExecutions<List<PendingMessage>>
NodeSelectionStreamAsyncCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.AsyncExecutions<List<PendingMessage>>
NodeSelectionStreamAsyncCommands. xpending(K key, XPendingArgs<K> args)
Read pending messages from a stream within a specificXPendingArgs
.AsyncExecutions<List<PendingMessage>>
NodeSelectionStreamAsyncCommands. xpending(K key, K group, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
. -
Uses of PendingMessage in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync that return types with arguments of type PendingMessage Modifier and Type Method Description Executions<List<PendingMessage>>
NodeSelectionStreamCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.Executions<List<PendingMessage>>
NodeSelectionStreamCommands. xpending(K key, XPendingArgs<K> args)
Read pending messages from a stream within a specificXPendingArgs
.Executions<List<PendingMessage>>
NodeSelectionStreamCommands. xpending(K key, K group, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
. -
Uses of PendingMessage in io.lettuce.core.models.stream
Methods in io.lettuce.core.models.stream that return types with arguments of type PendingMessage Modifier and Type Method Description static List<PendingMessage>
PendingParser. parseRange(List<?> xpendingOutput)
Parse the output of the Redis XPENDING command withRange
. -
Uses of PendingMessage in io.lettuce.core.output
Methods in io.lettuce.core.output that return types with arguments of type PendingMessage Modifier and Type Method Description StreamingOutput.Subscriber<PendingMessage>
PendingMessageListOutput. getSubscriber()
Method parameters in io.lettuce.core.output with type arguments of type PendingMessage Modifier and Type Method Description void
PendingMessageListOutput. setSubscriber(StreamingOutput.Subscriber<PendingMessage> subscriber)
-