Uses of Class
io.lettuce.core.XClaimArgs
-
Packages that use XClaimArgs 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 XClaimArgs in io.lettuce.core
Methods in io.lettuce.core that return XClaimArgs Modifier and Type Method Description XClaimArgs
XClaimArgs. force()
Creates the pending message entry in the PEL even if certain specified IDs are not already in the PEL assigned to a different client.XClaimArgs
XClaimArgs. force(boolean force)
Creates the pending message entry in the PEL even if certain specified IDs are not already in the PEL assigned to a different client.XClaimArgs
XClaimArgs. idle(long milliseconds)
Set the idle time (last time it was delivered) of the message.XClaimArgs
XClaimArgs. idle(Duration idleTime)
Set the idle time (last time it was delivered) of the message.static XClaimArgs
XClaimArgs.Builder. justid()
Creates newXClaimArgs
and set theJUSTID
flag to return just the message id and do not increment the retry counter.XClaimArgs
XClaimArgs. justid()
Set theJUSTID
flag to return just the message id and do not increment the retry counter.static XClaimArgs
XClaimArgs.Builder. minIdleTime(long milliseconds)
static XClaimArgs
XClaimArgs.Builder. minIdleTime(Duration minIdleTime)
Creates newXClaimArgs
and set the minimum idle time.XClaimArgs
XClaimArgs. minIdleTime(long milliseconds)
Return only messages that are idle for at leastmilliseconds
.XClaimArgs
XClaimArgs. minIdleTime(Duration minIdleTime)
Return only messages that are idle for at leastminIdleTime
.XClaimArgs
XClaimArgs. retryCount(long retrycount)
Set the retry counter to the specified value.XClaimArgs
XClaimArgs. time(long millisecondsUnixTime)
This is the same as IDLE but instead of a relative amount of milliseconds, it sets the idle time to a specific unix time (in milliseconds).XClaimArgs
XClaimArgs. time(TemporalAccessor timestamp)
This is the same as IDLE but instead of a relative amount of milliseconds, it sets the idle time to a specific unix time (in milliseconds).Methods in io.lettuce.core with parameters of type XClaimArgs Modifier and Type Method Description RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
-
Uses of XClaimArgs in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type XClaimArgs Modifier and Type Method Description RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group. -
Uses of XClaimArgs in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type XClaimArgs Modifier and Type Method Description Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group. -
Uses of XClaimArgs in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type XClaimArgs Modifier and Type Method Description List<StreamMessage<K,V>>
RedisStreamCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group. -
Uses of XClaimArgs in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type XClaimArgs Modifier and Type Method Description AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group. -
Uses of XClaimArgs in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type XClaimArgs Modifier and Type Method Description Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
-