Uses of Class
org.springframework.data.redis.connection.RedisStreamCommands.XClaimOptions
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Core package for integrating Redis with Spring concepts.
-
Uses of RedisStreamCommands.XClaimOptions in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionRedisStreamCommands.XClaimOptions.force()
Forces creation of a pending message entry in the PEL even if it does not already exist as long a the given stream record id is valid.ReactiveStreamCommands.XClaimCommand.getOptions()
Set the idle time since last delivery of a message.Set the IDs to claim.Set the IDs to claim.Set the IDs to claim.RedisStreamCommands.XClaimOptions.retryCount
(long retryCount) Set the retry counter to the specified value.Sets the idle time to a specific unix time (in milliseconds).Modifier and TypeMethodDescriptiondefault List<ByteRecord>
DefaultedRedisConnection.xClaim
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Deprecated.DefaultStringRedisConnection.xClaim
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) DefaultStringRedisConnection.xClaim
(String key, String group, String consumer, RedisStreamCommands.XClaimOptions options) default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xClaim
(ByteBuffer key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.RedisStreamCommands.xClaim
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.StringRedisConnection.xClaim
(String key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.DefaultedRedisConnection.xClaimJustId
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.DefaultStringRedisConnection.xClaimJustId
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) DefaultStringRedisConnection.xClaimJustId
(String key, String group, String consumer, RedisStreamCommands.XClaimOptions options) default reactor.core.publisher.Flux<RecordId>
ReactiveStreamCommands.xClaimJustId
(ByteBuffer key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count.RedisStreamCommands.xClaimJustId
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count.StringRedisConnection.xClaimJustId
(String key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count. -
Uses of RedisStreamCommands.XClaimOptions in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionReactiveStreamOperations.claim
(K key, String consumerGroup, String newOwner, RedisStreamCommands.XClaimOptions xClaimOptions) Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.StreamOperations.claim
(K key, String consumerGroup, String newOwner, RedisStreamCommands.XClaimOptions xClaimOptions) Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.
RedisCommandsProvider.streamCommands()
}.