Package io.valkey.springframework.data.valkey.connection

Class ReactiveZSetCommands.BZPopCommand

java.lang.Object

io.valkey.springframework.data.valkey.connection.ReactiveValkeyConnection.KeyCommand

io.valkey.springframework.data.valkey.connection.ReactiveZSetCommands.BZPopCommand

All Implemented Interfaces:

ReactiveValkeyConnection.Command

Enclosing interface:

ReactiveZSetCommands

public static class ReactiveZSetCommands.BZPopCommand
extends ReactiveValkeyConnection.KeyCommand

BZPOPMIN/BZPOPMAX command parameters.

Since:

2.6

Author:

Mark Paluch

See Also:

• Valkey Documentation: BZPOPMIN
• Valkey Documentation: BZPOPMAX

Method Summary

Modifier and Type	Method	Description
ReactiveZSetCommands.BZPopCommand	blockingFor(long timeout, TimeUnit timeUnit)	Applies a timeout.
ReactiveZSetCommands.BZPopCommand	blockingFor(Duration timeout)	Applies a timeout.
ReactiveZSetCommands.BZPopCommand	count(long count)	Applies the key.
ReactiveZSetCommands.BZPopCommand	from(ByteBuffer key)	Applies the key.
long	getCount()
ReactiveZSetCommands.PopDirection	getDirection()
Long	getTimeout()
TimeUnit	getTimeUnit()
static ReactiveZSetCommands.BZPopCommand	max()	Creates a new ReactiveZSetCommands.BZPopCommand for max pop (ZPOPMAX).
static ReactiveZSetCommands.BZPopCommand	min()	Creates a new ReactiveZSetCommands.BZPopCommand for min pop (ZPOPMIN).

Methods inherited from class io.valkey.springframework.data.valkey.connection.ReactiveValkeyConnection.KeyCommand

getKey

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.valkey.springframework.data.valkey.connection.ReactiveValkeyConnection.Command

getName

Method Details

min

public static ReactiveZSetCommands.BZPopCommand min()

Creates a new ReactiveZSetCommands.BZPopCommand for min pop (ZPOPMIN).

Returns:

a new ReactiveZSetCommands.BZPopCommand for min pop (ZPOPMIN).

max

public static ReactiveZSetCommands.BZPopCommand max()

Creates a new ReactiveZSetCommands.BZPopCommand for max pop (ZPOPMAX).

Returns:

a new ReactiveZSetCommands.BZPopCommand for max pop (ZPOPMAX).

from

public ReactiveZSetCommands.BZPopCommand from(ByteBuffer key)

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

Parameters:

key - must not be null.

Returns:

a new ReactiveZSetCommands.BZPopCommand with value applied.

count

public ReactiveZSetCommands.BZPopCommand count(long count)

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

Parameters:

count -

Returns:

a new ReactiveZSetCommands.BZPopCommand with value applied.

blockingFor

public ReactiveZSetCommands.BZPopCommand 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 ReactiveZSetCommands.BZPopCommand with timeout applied.

blockingFor

public ReactiveZSetCommands.BZPopCommand blockingFor(long timeout,
 TimeUnit timeUnit)

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

Parameters:

timeout - value.

timeUnit - must not be null.

Returns:

a new ReactiveZSetCommands.BZPopCommand with timeout applied.

getDirection

public ReactiveZSetCommands.PopDirection getDirection()

Returns:

never null.

getTimeout

@Nullable
public Long getTimeout()

getTimeUnit

@Nullable
public TimeUnit getTimeUnit()

getCount

public long getCount()