Package org.infinispan.server.resp.commands.tx

Class WATCH

java.lang.Object

org.infinispan.server.resp.RespCommand

org.infinispan.server.resp.commands.tx.WATCH

All Implemented Interfaces:

Resp3Command, TransactionResp3Command

public class WATCH
extends RespCommand
implements Resp3Command, TransactionResp3Command

WATCH

Installs a clustered listener to watch for the given keys. The listener receives events for creation, updates, and expiration.

The watch instance is local to a single ChannelHandlerContext. To remove the listeners, the same context needs to execute the operation. There is no way to remove a single specific watcher. All listeners deregister during an EXEC, UNWATCH, DISCARD, transaction abort, or closed channel.

Since a listener is bound to a single connection, this ensures that another client does not affect each other's transactions safeguards.

Since:

15.0

Author:

José Bolina

See Also:

• invalid input: '<'

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WATCH.TxKeysListener

Field Summary

Fields

Modifier and Type	Field	Description
static final AdvancedExternalizer<org.infinispan.server.resp.commands.tx.WATCH.TxEventConverterEmpty>	EXTERNALIZER

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

log

Constructor Summary

Constructors

Constructor	Description
WATCH()

Method Summary

Modifier and Type	Method	Description
long	aclMask()
CompletionStage<RespRequestHandler>	perform(Resp3Handler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)
CompletionStage<RespRequestHandler>	perform(RespTransactionHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)
void	register(io.netty.channel.ChannelHandlerContext ctx, WATCH.TxKeysListener listener)

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

extractKeys, fromByteBuf, 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

Field Details

EXTERNALIZER

public static final AdvancedExternalizer<org.infinispan.server.resp.commands.tx.WATCH.TxEventConverterEmpty> EXTERNALIZER

Constructor Details

WATCH

public WATCH()

Method Details

aclMask

public long aclMask()

Specified by:

aclMask in class RespCommand

perform

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

Specified by:

perform in interface Resp3Command

perform

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

Specified by:

perform in interface TransactionResp3Command

register

public void register(io.netty.channel.ChannelHandlerContext ctx,
 WATCH.TxKeysListener listener)