Uses of Class
io.lettuce.core.models.stream.PendingMessage

Packages that use PendingMessage

Package	Description
io.lettuce.core	The Redis client package containing RedisClient 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 and Description
RedisFuture<List<PendingMessage>>	AbstractRedisAsyncCommands.xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Flux<PendingMessage>	AbstractRedisReactiveCommands.xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
RedisFuture<List<PendingMessage>>	AbstractRedisAsyncCommands.xpending(K key, K group, Range<String> range, Limit limit)
Flux<PendingMessage>	AbstractRedisReactiveCommands.xpending(K key, K group, Range<String> range, Limit limit)
RedisFuture<List<PendingMessage>>	AbstractRedisAsyncCommands.xpending(K key, XPendingArgs<K> args)
Flux<PendingMessage>	AbstractRedisReactiveCommands.xpending(K key, XPendingArgs<K> args)

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 and Description
RedisFuture<List<PendingMessage>>	RedisStreamAsyncCommands.xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
RedisFuture<List<PendingMessage>>	RedisStreamAsyncCommands.xpending(K key, K group, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
RedisFuture<List<PendingMessage>>	RedisStreamAsyncCommands.xpending(K key, XPendingArgs<K> args) Read pending messages from a stream within a specific XPendingArgs.

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 and Description
Flux<PendingMessage>	RedisStreamReactiveCommands.xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
Flux<PendingMessage>	RedisStreamReactiveCommands.xpending(K key, K group, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
Flux<PendingMessage>	RedisStreamReactiveCommands.xpending(K key, XPendingArgs<K> args) Read pending messages from a stream within a specific XPendingArgs.

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 and Description
List<PendingMessage>	RedisStreamCommands.xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
List<PendingMessage>	RedisStreamCommands.xpending(K key, K group, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
List<PendingMessage>	RedisStreamCommands.xpending(K key, XPendingArgs<K> args) Read pending messages from a stream within a specific XPendingArgs.

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 and Description
AsyncExecutions<List<PendingMessage>>	NodeSelectionStreamAsyncCommands.xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
AsyncExecutions<List<PendingMessage>>	NodeSelectionStreamAsyncCommands.xpending(K key, K group, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
AsyncExecutions<List<PendingMessage>>	NodeSelectionStreamAsyncCommands.xpending(K key, XPendingArgs<K> args) Read pending messages from a stream within a specific XPendingArgs.

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 and Description
Executions<List<PendingMessage>>	NodeSelectionStreamCommands.xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
Executions<List<PendingMessage>>	NodeSelectionStreamCommands.xpending(K key, K group, Range<String> range, Limit limit) Read pending messages from a stream within a specific Range.
Executions<List<PendingMessage>>	NodeSelectionStreamCommands.xpending(K key, XPendingArgs<K> args) Read pending messages from a stream within a specific XPendingArgs.

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 and Description
static List<PendingMessage>	PendingParser.parseRange(List<?> xpendingOutput) Parse the output of the Redis XPENDING command with Range.

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 and Description
StreamingOutput.Subscriber<PendingMessage>	PendingMessageListOutput.getSubscriber()

Method parameters in io.lettuce.core.output with type arguments of type PendingMessage

Modifier and Type	Method and Description
void	PendingMessageListOutput.setSubscriber(StreamingOutput.Subscriber<PendingMessage> subscriber)