public class Codec20 extends Object implements Codec, HotRodConstants
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, CONTAINS_KEY_REQUEST, CONTAINS_KEY_RESPONSE, DEFAULT_CACHE_NAME_BYTES, DEFAULT_CACHE_TOPOLOGY, ERROR_RESPONSE, EXEC_REQUEST, EXEC_RESPONSE, GET_ALL_REQUEST, GET_ALL_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, ILLEGAL_LIFECYCLE_STATE, 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_COMPAT, NODE_SUSPECTED, NOT_EXECUTED_WITH_PREVIOUS, NOT_EXECUTED_WITH_PREVIOUS_COMPAT, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PUT_ALL_REQUEST, PUT_ALL_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_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, SERVER_ERROR_STATUS, SIZE_REQUEST, SIZE_RESPONSE, STATS_REQUEST, STATS_RESPONSE, SUCCESS_WITH_PREVIOUS, SUCCESS_WITH_PREVIOUS_COMPAT, SWITCH_CLUSTER_TOPOLOGY, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_10, VERSION_11, VERSION_12, VERSION_13, VERSION_20, VERSION_21, VERSION_22, VERSION_23, VERSION_24, VERSION_25
Constructor and Description |
---|
Codec20() |
Modifier and Type | Method and Description |
---|---|
protected void |
checkForErrorsInResponseStatus(Transport transport,
HeaderParams params,
short status) |
protected ClientCacheEntryCreatedEvent<Object> |
createCreatedEvent(Object key,
long dataVersion,
boolean isRetried) |
protected ClientCacheEntryCustomEvent<Object> |
createCustomEvent(Object eventData,
ClientEvent.Type eventType,
boolean isRetried) |
protected ClientCacheEntryModifiedEvent |
createModifiedEvent(Object key,
long dataVersion,
boolean isRetried) |
protected ClientEvent |
createRemovedEvent(Object key,
boolean isRetried) |
Log |
getLog()
Logger for Hot Rod client codec
|
ClientEvent |
readEvent(Transport transport,
byte[] expectedListenerId,
Marshaller marshaller,
List<String> whitelist) |
short |
readHeader(Transport transport,
HeaderParams params)
Reads a response header from the transport and returns the status
of the response.
|
Either<Short,ClientEvent> |
readHeaderOrEvent(Transport transport,
HeaderParams params,
byte[] expectedListenerId,
Marshaller marshaller,
List<String> whitelist) |
protected void |
readNewTopologyAndHash(Transport transport,
HeaderParams params) |
protected void |
readNewTopologyIfPresent(Transport transport,
HeaderParams params) |
protected ClientEvent |
readPartialEvent(Transport transport,
byte[] expectedListenerId,
Marshaller marshaller,
short eventTypeId,
List<String> whitelist) |
<T> T |
readUnmarshallByteArray(Transport transport,
short status,
List<String> whitelist)
Read and unmarshall byte array.
|
Object |
returnPossiblePrevValue(Transport transport,
short status,
int flags,
List<String> whitelist) |
void |
writeClientListenerParams(Transport transport,
ClientListener clientListener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams)
Writes client listener parameters
|
void |
writeExpirationParams(Transport transport,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit)
Write lifespan/maxidle parameters.
|
HeaderParams |
writeHeader(Transport transport,
HeaderParams params)
Writes a request header with the given parameters to the transport and
returns an updated header parameters.
|
protected HeaderParams |
writeHeader(Transport transport,
HeaderParams params,
byte version) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
hasCompatibility, hasPrevious, isInvalidIteration, isNotExecuted, isNotExist, isSuccess
public <T> T readUnmarshallByteArray(Transport transport, short status, List<String> whitelist)
Codec
readUnmarshallByteArray
in interface Codec
public HeaderParams writeHeader(Transport transport, HeaderParams params)
Codec
writeHeader
in interface Codec
public void writeClientListenerParams(Transport transport, ClientListener clientListener, byte[][] filterFactoryParams, byte[][] converterFactoryParams)
Codec
writeClientListenerParams
in interface Codec
public void writeExpirationParams(Transport transport, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit)
Codec
writeExpirationParams
in interface Codec
protected HeaderParams writeHeader(Transport transport, HeaderParams params, byte version)
public short readHeader(Transport transport, HeaderParams params)
Codec
readHeader
in interface Codec
public ClientEvent readEvent(Transport transport, byte[] expectedListenerId, Marshaller marshaller, List<String> whitelist)
protected ClientEvent readPartialEvent(Transport transport, byte[] expectedListenerId, Marshaller marshaller, short eventTypeId, List<String> whitelist)
public Either<Short,ClientEvent> readHeaderOrEvent(Transport transport, HeaderParams params, byte[] expectedListenerId, Marshaller marshaller, List<String> whitelist)
readHeaderOrEvent
in interface Codec
public Object returnPossiblePrevValue(Transport transport, short status, int flags, List<String> whitelist)
returnPossiblePrevValue
in interface Codec
protected ClientEvent createRemovedEvent(Object key, boolean isRetried)
protected ClientCacheEntryModifiedEvent createModifiedEvent(Object key, long dataVersion, boolean isRetried)
protected ClientCacheEntryCreatedEvent<Object> createCreatedEvent(Object key, long dataVersion, boolean isRetried)
protected ClientCacheEntryCustomEvent<Object> createCustomEvent(Object eventData, ClientEvent.Type eventType, boolean isRetried)
protected void checkForErrorsInResponseStatus(Transport transport, HeaderParams params, short status)
protected void readNewTopologyIfPresent(Transport transport, HeaderParams params)
protected void readNewTopologyAndHash(Transport transport, HeaderParams params)
Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.