Uses of Class
org.springframework.data.redis.connection.ReactiveStreamCommands.XClaimCommand

Packages that use ReactiveStreamCommands.XClaimCommand

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.

Uses of ReactiveStreamCommands.XClaimCommand in org.springframework.data.redis.connection

Methods in org.springframework.data.redis.connection that return types with arguments of type ReactiveStreamCommands.XClaimCommand

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	ReactiveStreamCommands.xClaim(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<RecordId>>>	ReactiveStreamCommands.xClaimJustId(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.

Method parameters in org.springframework.data.redis.connection with type arguments of type ReactiveStreamCommands.XClaimCommand

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	ReactiveStreamCommands.xClaim(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<RecordId>>>	ReactiveStreamCommands.xClaimJustId(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.