@Immutable public abstract class HotRodOperation<T> extends CompletableFuture<T> implements HotRodConstants, Runnable
Flag
s and it is targeted against a
cache name. This base class encapsulates the knowledge of writing and reading a header, as described in the
Hot Rod protocol specificationCompletableFuture.AsynchronousCompletionTask
HotRodConstants.Names
Modifier and Type | Field and Description |
---|---|
byte[] |
cacheName |
protected Configuration |
cfg |
protected ChannelFactory |
channelFactory |
protected Codec |
codec |
protected DataFormat |
dataFormat |
protected int |
flags |
protected HeaderParams |
header |
protected ScheduledFuture<?> |
timeoutFuture |
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, CLIENT_INTELLIGENCE_BASIC, CLIENT_INTELLIGENCE_HASH_DISTRIBUTION_AWARE, CLIENT_INTELLIGENCE_TOPOLOGY_AWARE, 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_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_BYTES, DEFAULT_CACHE_TOPOLOGY, 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, 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, STATS_REQUEST, STATS_RESPONSE, SUCCESS_WITH_PREVIOUS, SUCCESS_WITH_PREVIOUS_OBJ_STORAGE, SWITCH_CLUSTER_TOPOLOGY, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_20, VERSION_21, VERSION_22, VERSION_23, VERSION_24, VERSION_25, VERSION_26, VERSION_27, VERSION_28, VERSION_29, VERSION_30
Modifier | Constructor and Description |
---|---|
protected |
HotRodOperation(short requestCode,
short responseCode,
Codec codec,
int flags,
Configuration cfg,
byte[] cacheName,
AtomicInteger topologyId,
ChannelFactory channelFactory) |
protected |
HotRodOperation(short requestCode,
short responseCode,
Codec codec,
int flags,
Configuration cfg,
byte[] cacheName,
AtomicInteger topologyId,
ChannelFactory channelFactory,
DataFormat dataFormat) |
Modifier and Type | Method and Description |
---|---|
abstract void |
acceptResponse(io.netty.buffer.ByteBuf buf,
short status,
HeaderDecoder decoder) |
protected void |
addParams(StringBuilder sb) |
void |
channelInactive(io.netty.channel.Channel channel) |
boolean |
complete(T value) |
void |
exceptionCaught(io.netty.channel.Channel channel,
Throwable cause) |
abstract CompletableFuture<T> |
execute() |
HeaderParams |
header() |
void |
releaseChannel(io.netty.channel.Channel channel) |
void |
run() |
protected void |
scheduleRead(io.netty.channel.Channel channel) |
void |
scheduleTimeout(io.netty.channel.Channel channel) |
protected void |
sendArrayOperation(io.netty.channel.Channel channel,
byte[] array) |
protected void |
sendHeader(io.netty.channel.Channel channel) |
protected void |
sendHeaderAndRead(io.netty.channel.Channel channel) |
String |
toString() |
acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, completedFuture, completeExceptionally, exceptionally, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, obtrudeException, obtrudeValue, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
hasPrevious, isInvalidIteration, isNotExecuted, isNotExist, isObjectStorage, isSuccess
public final byte[] cacheName
protected final int flags
protected final Codec codec
protected final Configuration cfg
protected final ChannelFactory channelFactory
protected final DataFormat dataFormat
protected final HeaderParams header
protected volatile ScheduledFuture<?> timeoutFuture
protected HotRodOperation(short requestCode, short responseCode, Codec codec, int flags, Configuration cfg, byte[] cacheName, AtomicInteger topologyId, ChannelFactory channelFactory, DataFormat dataFormat)
protected HotRodOperation(short requestCode, short responseCode, Codec codec, int flags, Configuration cfg, byte[] cacheName, AtomicInteger topologyId, ChannelFactory channelFactory)
public abstract CompletableFuture<T> execute()
public HeaderParams header()
protected void sendHeaderAndRead(io.netty.channel.Channel channel)
protected void sendHeader(io.netty.channel.Channel channel)
protected void scheduleRead(io.netty.channel.Channel channel)
public void releaseChannel(io.netty.channel.Channel channel)
public void channelInactive(io.netty.channel.Channel channel)
public void exceptionCaught(io.netty.channel.Channel channel, Throwable cause)
protected void sendArrayOperation(io.netty.channel.Channel channel, byte[] array)
public abstract void acceptResponse(io.netty.buffer.ByteBuf buf, short status, HeaderDecoder decoder)
public String toString()
toString
in class CompletableFuture<T>
protected void addParams(StringBuilder sb)
public boolean complete(T value)
complete
in class CompletableFuture<T>
public void scheduleTimeout(io.netty.channel.Channel channel)
Copyright © 2021 JBoss by Red Hat. All rights reserved.