Package org.springframework.data.redis.connection

Class ReactiveListCommands.BPopCommand

java.lang.Object

org.springframework.data.redis.connection.ReactiveListCommands.BPopCommand

All Implemented Interfaces:

ReactiveRedisConnection.Command

Enclosing interface:

ReactiveListCommands

public static class ReactiveListCommands.BPopCommand
extends Object
implements ReactiveRedisConnection.Command

Author:

Christoph Strobl

See Also:

• Redis Documentation: BLPOP
• Redis Documentation: BRPOP

Method Summary

Modifier and Type	Method	Description
ReactiveListCommands.BPopCommand	blockingFor(Duration timeout)	Applies a timeout.
ReactiveListCommands.BPopCommand	from(List<ByteBuffer> keys)	Applies the value.
ReactiveListCommands.Direction	getDirection()
ByteBuffer	getKey()
List<ByteBuffer>	getKeys()
Duration	getTimeout()
static ReactiveListCommands.BPopCommand	left()	Creates a new ReactiveListCommands.BPopCommand for right push (BLPOP).
static ReactiveListCommands.BPopCommand	right()	Creates a new ReactiveListCommands.BPopCommand for right push (BRPOP).

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

right

public static ReactiveListCommands.BPopCommand right()

Creates a new ReactiveListCommands.BPopCommand for right push (BRPOP).

Returns:

a new ReactiveListCommands.BPopCommand for right push (BRPOP).

left

public static ReactiveListCommands.BPopCommand left()

Creates a new ReactiveListCommands.BPopCommand for right push (BLPOP).

Returns:

a new ReactiveListCommands.BPopCommand for right push (BLPOP).

from

public ReactiveListCommands.BPopCommand from(List<ByteBuffer> keys)

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

Parameters:

keys - must not be null.

Returns:

a new ReactiveListCommands.BPopCommand with value applied.

blockingFor

public ReactiveListCommands.BPopCommand 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.BPopCommand with timeout applied.

getKey

public ByteBuffer getKey()

Specified by:

getKey in interface ReactiveRedisConnection.Command

Returns:

the key related to this command.

getKeys

public List<ByteBuffer> getKeys()

Returns:

getTimeout

public Duration getTimeout()

Returns:

getDirection

public ReactiveListCommands.Direction getDirection()

Returns: