Uses of Class
io.lettuce.core.models.stream.ClaimedMessages
-
Packages that use ClaimedMessages 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. -
-
Uses of ClaimedMessages in io.lettuce.core
Methods in io.lettuce.core that return types with arguments of type ClaimedMessages Modifier and Type Method Description RedisFuture<ClaimedMessages<K,V>>
AbstractRedisAsyncCommands. xautoclaim(K key, XAutoClaimArgs<K> args)
Mono<ClaimedMessages<K,V>>
AbstractRedisReactiveCommands. xautoclaim(K key, XAutoClaimArgs<K> args)
-
Uses of ClaimedMessages in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async that return types with arguments of type ClaimedMessages Modifier and Type Method Description RedisFuture<ClaimedMessages<K,V>>
RedisStreamAsyncCommands. xautoclaim(K key, XAutoClaimArgs<K> args)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group. -
Uses of ClaimedMessages in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive that return types with arguments of type ClaimedMessages Modifier and Type Method Description Mono<ClaimedMessages<K,V>>
RedisStreamReactiveCommands. xautoclaim(K key, XAutoClaimArgs<K> args)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group. -
Uses of ClaimedMessages in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync that return ClaimedMessages Modifier and Type Method Description ClaimedMessages<K,V>
RedisStreamCommands. xautoclaim(K key, XAutoClaimArgs<K> args)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group. -
Uses of ClaimedMessages in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async that return types with arguments of type ClaimedMessages Modifier and Type Method Description AsyncExecutions<ClaimedMessages<K,V>>
NodeSelectionStreamAsyncCommands. xautoclaim(K key, XAutoClaimArgs<K> args)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group. -
Uses of ClaimedMessages in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync that return types with arguments of type ClaimedMessages Modifier and Type Method Description Executions<ClaimedMessages<K,V>>
NodeSelectionStreamCommands. xautoclaim(K key, XAutoClaimArgs<K> args)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
-