org.infinispan.client.hotrod.impl.operations

Class HotRodOperation

java.lang.Object

org.infinispan.client.hotrod.impl.operations.HotRodOperation

All Implemented Interfaces:

HotRodConstants

Direct Known Subclasses:

PingOperation, RetryOnFailureOperation

@Immutable
public abstract class HotRodOperation
extends Object
implements HotRodConstants

Generic Hot Rod operation. It is aware of Flags 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 specification

Since:

4.1

Author:

Mircea.Markus@jboss.com

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	cacheName
protected Codec	codec
protected Flag[]	flags
protected AtomicInteger	topologyId

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

BULK_GET_KEYS_REQUEST, BULK_GET_KEYS_RESPONSE, BULK_GET_REQUEST, BULK_GET_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, ERROR_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INVALID_MAGIC_OR_MESSAGE_ID_STATUS, KEY_DOES_NOT_EXIST_STATUS, NO_ERROR_STATUS, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_RESPONSE, QUERY_REQUEST, QUERY_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, STATS_REQUEST, STATS_RESPONSE, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_10, VERSION_11, VERSION_12

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HotRodOperation(Codec codec, Flag[] flags, byte[] cacheName, AtomicInteger topologyId)

Method Summary

Methods

Modifier and Type	Method and Description
abstract Object	execute()
protected short	readHeaderAndValidate(Transport transport, HeaderParams params) Magic | Message Id | Op code | Status | Topology Change Marker
protected HeaderParams	writeHeader(Transport transport, short operationCode)

Methods inherited from class java.lang.Object

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

Field Detail

flags

protected final Flag[] flags

cacheName

protected final byte[] cacheName

topologyId

protected final AtomicInteger topologyId

codec

protected final Codec codec

Constructor Detail

HotRodOperation

protected HotRodOperation(Codec codec,
               Flag[] flags,
               byte[] cacheName,
               AtomicInteger topologyId)

Method Detail

execute

public abstract Object execute()

writeHeader

protected final HeaderParams writeHeader(Transport transport,
                       short operationCode)

readHeaderAndValidate

protected short readHeaderAndValidate(Transport transport,
                          HeaderParams params)

Magic | Message Id | Op code | Status | Topology Change Marker