Package org.springframework.data.redis.connection

Class ReactiveListCommands.BRPopLPushCommand

java.lang.Object

org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand

org.springframework.data.redis.connection.ReactiveListCommands.BRPopLPushCommand

All Implemented Interfaces:

ReactiveRedisConnection.Command

Enclosing interface:

ReactiveListCommands

public static class ReactiveListCommands.BRPopLPushCommand
extends ReactiveRedisConnection.KeyCommand

BRPOPLPUSH command parameters.

Author:

Christoph Strobl

See Also:

• Redis Documentation: BRPOPLPUSH

Method Summary

Modifier and Type	Method	Description
ReactiveListCommands.BRPopLPushCommand	blockingFor(Duration timeout)	Applies a timeout.
static ReactiveListCommands.BRPopLPushCommand	from(ByteBuffer sourceKey)	Creates a new ReactiveListCommands.BRPopLPushCommand given a sourceKey.
ByteBuffer	getDestination()
Duration	getTimeout()
ReactiveListCommands.BRPopLPushCommand	to(ByteBuffer destinationKey)	Applies the destinationKey.

Methods inherited from class org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand

getKey

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.redis.connection.ReactiveRedisConnection.Command

getName

Method Details

from

public static ReactiveListCommands.BRPopLPushCommand from(ByteBuffer sourceKey)

Creates a new ReactiveListCommands.BRPopLPushCommand given a sourceKey.

Parameters:

sourceKey - must not be null.

Returns:

a new ReactiveListCommands.BRPopLPushCommand for a sourceKey.

to

public ReactiveListCommands.BRPopLPushCommand to(ByteBuffer destinationKey)

Applies the destinationKey. Constructs a new command instance with all previously configured properties.

Parameters:

destinationKey - must not be null.

Returns:

a new ReactiveListCommands.BRPopLPushCommand with value applied.

blockingFor

public ReactiveListCommands.BRPopLPushCommand blockingFor(Duration timeout)

Applies a timeout. Constructs a new command instance with all previously configured properties.

Parameters:

timeout - must not be null.

Returns:

a new ReactiveListCommands.BRPopLPushCommand with timeout applied.

getDestination

@Nullable
public ByteBuffer getDestination()

Returns:

can be null.

getTimeout

public Duration getTimeout()

Returns:

never null.