Class AbstractBlockingPop

java.lang.Object

org.infinispan.server.resp.RespCommand

org.infinispan.server.resp.commands.list.blocking.AbstractBlockingPop

All Implemented Interfaces:

BaseResp3Command, Resp3Command

Direct Known Subclasses:

BLMPOP, BLPOP, BRPOP

public abstract class AbstractBlockingPop
extends RespCommand
implements Resp3Command

Derogating to the command documentation, when multiple client are blocked on a BLPOP, the order in which they will be served is unspecified.

Since:

15.0

See Also:

• BLPOP

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractBlockingPop.PollListenerSynchronizer	PollListenerSynchronizer This class synchronizes the access to a CompletableFuture `resultFuture` so that its final value will be completed either - with value v by an onListenerAdded() call if a not null value is found - otherwise by onEvent(k) call if the referred entry is not null or empty
static class	AbstractBlockingPop.PubSubListener

Constructor Summary

Constructors

Constructor	Description
AbstractBlockingPop(int arity, int firstKeyPos, int lastKeyPos, int steps)

Method Summary

Modifier and Type	Method	Description
CompletionStage<RespRequestHandler>	perform(Resp3Handler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)

Methods inherited from class org.infinispan.server.resp.RespCommand

extractKeys, fromByteBuf, fromString, getArity, getFirstKeyPos, getLastKeyPos, getName, getSteps, handleException, hasValidNumberOfArguments, match, size, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.server.resp.commands.BaseResp3Command

aclMask

Constructor Details

AbstractBlockingPop

public AbstractBlockingPop(int arity,
 int firstKeyPos,
 int lastKeyPos,
 int steps)

Method Details

perform

public CompletionStage<RespRequestHandler> perform(Resp3Handler handler,
 io.netty.channel.ChannelHandlerContext ctx,
 List<byte[]> arguments)

Specified by:

perform in interface Resp3Command