Package org.infinispan.client.hotrod.counter.operation

Class AddListenerOperation

java.lang.Object

java.util.concurrent.CompletableFuture<io.netty.channel.Channel>

org.infinispan.client.hotrod.impl.operations.AbstractHotRodOperation<io.netty.channel.Channel>

org.infinispan.client.hotrod.impl.operations.AbstractNoCacheHotRodOperation<io.netty.channel.Channel>

org.infinispan.client.hotrod.counter.operation.AddListenerOperation

All Implemented Interfaces:

CompletionStage<io.netty.channel.Channel>, Future<io.netty.channel.Channel>, org.infinispan.client.hotrod.impl.operations.HotRodOperation<io.netty.channel.Channel>, org.infinispan.client.hotrod.impl.protocol.HotRodConstants

public class AddListenerOperation
extends org.infinispan.client.hotrod.impl.operations.AbstractNoCacheHotRodOperation<io.netty.channel.Channel>

An add listener operation for StrongCounter.addListener(CounterListener) and WeakCounter.addListener(CounterListener)

Since:

9.2

Author:

Pedro Ruivo

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Nested classes/interfaces inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants

org.infinispan.client.hotrod.impl.protocol.HotRodConstants.Names

Field Summary

Fields inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants

ADD_BLOOM_FILTER_NEAR_CACHE_LISTENER_REQUEST, ADD_BLOOM_FILTER_NEAR_CACHE_LISTENER_RESPONSE, ADD_CLIENT_LISTENER_REQUEST, ADD_CLIENT_LISTENER_RESPONSE, AUTH_MECH_LIST_REQUEST, AUTH_MECH_LIST_RESPONSE, AUTH_REQUEST, AUTH_RESPONSE, BULK_GET_KEYS_REQUEST, BULK_GET_KEYS_RESPONSE, BULK_GET_REQUEST, BULK_GET_RESPONSE, CACHE_ENTRY_CREATED_EVENT_RESPONSE, CACHE_ENTRY_EXPIRED_EVENT_RESPONSE, CACHE_ENTRY_MODIFIED_EVENT_RESPONSE, CACHE_ENTRY_REMOVED_EVENT_RESPONSE, CLEAR_REQUEST, CLEAR_RESPONSE, COMMAND_TIMEOUT_STATUS, COMMIT_REQUEST, COMMIT_RESPONSE, CONTAINS_KEY_REQUEST, CONTAINS_KEY_RESPONSE, COUNTER_ADD_AND_GET_REQUEST, COUNTER_ADD_AND_GET_RESPONSE, COUNTER_ADD_LISTENER_REQUEST, COUNTER_ADD_LISTENER_RESPONSE, COUNTER_CAS_REQUEST, COUNTER_CAS_RESPONSE, COUNTER_CREATE_REQUEST, COUNTER_CREATE_RESPONSE, COUNTER_EVENT_RESPONSE, COUNTER_GET_AND_SET_REQUEST, COUNTER_GET_AND_SET_RESPONSE, COUNTER_GET_CONFIGURATION_REQUEST, COUNTER_GET_CONFIGURATION_RESPONSE, COUNTER_GET_NAMES_REQUEST, COUNTER_GET_NAMES_RESPONSE, COUNTER_GET_REQUEST, COUNTER_GET_RESPONSE, COUNTER_IS_DEFINED_REQUEST, COUNTER_IS_DEFINED_RESPONSE, COUNTER_REMOVE_LISTENER_REQUEST, COUNTER_REMOVE_LISTENER_RESPONSE, COUNTER_REMOVE_REQUEST, COUNTER_REMOVE_RESPONSE, COUNTER_RESET_REQUEST, COUNTER_RESET_RESPONSE, DEFAULT_CACHE_NAME, DEFAULT_CACHE_NAME_BYTES, DEFAULT_CACHE_TOPOLOGY, END_GET_STREAM_REQUEST, END_GET_STREAM_RESPONSE, END_PUT_STREAM_REQUEST, END_PUT_STREAM_RESPONSE, ERROR_RESPONSE, EXEC_REQUEST, EXEC_RESPONSE, FETCH_TX_RECOVERY_REQUEST, FETCH_TX_RECOVERY_RESPONSE, FORGET_TX_REQUEST, FORGET_TX_RESPONSE, GET_ALL_REQUEST, GET_ALL_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_STREAM_REQUEST, GET_STREAM_RESPONSE, GET_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, ILLEGAL_LIFECYCLE_STATE, ILLEGAL_OP_CODE, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INVALID_ITERATION, INVALID_MAGIC_OR_MESSAGE_ID_STATUS, ITERATION_END_REQUEST, ITERATION_END_RESPONSE, ITERATION_NEXT_REQUEST, ITERATION_NEXT_RESPONSE, ITERATION_START_REQUEST, ITERATION_START_RESPONSE, KEY_DOES_NOT_EXIST_STATUS, NEXT_GET_STREAM_REQUEST, NEXT_GET_STREAM_RESPONSE, NEXT_PUT_STREAM_REQUEST, NEXT_PUT_STREAM_RESPONSE, NO_ERROR_STATUS, NO_ERROR_STATUS_OBJ_STORAGE, NODE_SUSPECTED, NOT_EXECUTED_WITH_PREVIOUS, NOT_EXECUTED_WITH_PREVIOUS_OBJ_STORAGE, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PREPARE_REQUEST, PREPARE_RESPONSE, PREPARE_TX_2_REQUEST, PREPARE_TX_2_RESPONSE, PUT_ALL_REQUEST, PUT_ALL_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_RESPONSE, PUT_STREAM_REQUEST, PUT_STREAM_RESPONSE, QUERY_REQUEST, QUERY_RESPONSE, REMOVE_CLIENT_LISTENER_REQUEST, REMOVE_CLIENT_LISTENER_RESPONSE, REMOVE_IF_UNMODIFIED_REQUEST, REMOVE_IF_UNMODIFIED_RESPONSE, REMOVE_REQUEST, REMOVE_RESPONSE, REPLACE_IF_UNMODIFIED_REQUEST, REPLACE_IF_UNMODIFIED_RESPONSE, REPLACE_REQUEST, REPLACE_RESPONSE, REQUEST_MAGIC, REQUEST_PARSING_ERROR_STATUS, RESPONSE_MAGIC, ROLLBACK_REQUEST, ROLLBACK_RESPONSE, SERVER_ERROR_STATUS, SIZE_REQUEST, SIZE_RESPONSE, START_GET_STREAM_REQUEST, START_GET_STREAM_RESPONSE, START_PUT_STREAM_REQUEST, START_PUT_STREAM_RESPONSE, STATS_REQUEST, STATS_RESPONSE, SUCCESS_WITH_PREVIOUS, SUCCESS_WITH_PREVIOUS_OBJ_STORAGE, SWITCH_CLUSTER_TOPOLOGY, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, UPDATE_BLOOM_FILTER_REQUEST, UPDATE_BLOOM_FILTER_RESPONSE, VERSION_30, VERSION_31, VERSION_40, VERSION_41

Constructor Summary

Constructors

Constructor	Description
AddListenerOperation(String counterName, byte[] listenerId)

Method Summary

Modifier and Type	Method	Description
protected void	addParams(StringBuilder sb)
io.netty.channel.Channel	createResponse(io.netty.buffer.ByteBuf buf, short status, org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder decoder, org.infinispan.client.hotrod.impl.protocol.Codec codec, org.infinispan.client.hotrod.impl.operations.CacheUnmarshaller unmarshaller)
String	getCacheName()
byte[]	getCacheNameBytes()
Object	getRoutingObject()
short	requestOpCode()
short	responseOpCode()
void	writeOperationRequest(io.netty.channel.Channel channel, io.netty.buffer.ByteBuf buf, org.infinispan.client.hotrod.impl.protocol.Codec codec)

Methods inherited from class org.infinispan.client.hotrod.impl.operations.AbstractNoCacheHotRodOperation

flags, getDataFormat, supportRetry

Methods inherited from class org.infinispan.client.hotrod.impl.operations.AbstractHotRodOperation

additionalParameters, asCompletableFuture, handleStatsCompletion, isInstanceOf, reset, timeout, toString

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class java.lang.Object

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

Constructor Details

AddListenerOperation

public AddListenerOperation(String counterName,
 byte[] listenerId)

Method Details

writeOperationRequest

public void writeOperationRequest(io.netty.channel.Channel channel,
 io.netty.buffer.ByteBuf buf,
 org.infinispan.client.hotrod.impl.protocol.Codec codec)

Specified by:

writeOperationRequest in interface org.infinispan.client.hotrod.impl.operations.HotRodOperation<io.netty.channel.Channel>

createResponse

public io.netty.channel.Channel createResponse(io.netty.buffer.ByteBuf buf,
 short status,
 org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder decoder,
 org.infinispan.client.hotrod.impl.protocol.Codec codec,
 org.infinispan.client.hotrod.impl.operations.CacheUnmarshaller unmarshaller)

requestOpCode

public short requestOpCode()

responseOpCode

public short responseOpCode()

getCacheName

public String getCacheName()

Specified by:

getCacheName in interface org.infinispan.client.hotrod.impl.operations.HotRodOperation<T>

Overrides:

getCacheName in class org.infinispan.client.hotrod.impl.operations.AbstractNoCacheHotRodOperation<T>

getCacheNameBytes

public byte[] getCacheNameBytes()

Specified by:

getCacheNameBytes in interface org.infinispan.client.hotrod.impl.operations.HotRodOperation<T>

Overrides:

getCacheNameBytes in class org.infinispan.client.hotrod.impl.operations.AbstractNoCacheHotRodOperation<T>

getRoutingObject

public Object getRoutingObject()

Specified by:

getRoutingObject in interface org.infinispan.client.hotrod.impl.operations.HotRodOperation<T>

Overrides:

getRoutingObject in class org.infinispan.client.hotrod.impl.operations.AbstractNoCacheHotRodOperation<T>

addParams

protected void addParams(StringBuilder sb)

Overrides:

addParams in class org.infinispan.client.hotrod.impl.operations.AbstractHotRodOperation<T>