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

protected byte[]	cacheName
protected Flag[]	flags
protected AtomicInteger	topologyId

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

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_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, HOTROD_VERSION, 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, 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

Constructor Summary

protected

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

Method Summary

protected void	checkForErrorsInResponseStatus(short status, long messageId, Transport transport)
abstract Object	execute()
protected short	readHeaderAndValidate(Transport transport, long messageId, short opRespCode) Magic | Message Id | Op code | Status | Topology Change Marker
protected long	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

Constructor Detail

HotRodOperation

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

Method Detail

execute

public abstract Object execute()

writeHeader

protected final long writeHeader(Transport transport,
                                 short operationCode)

readHeaderAndValidate

protected short readHeaderAndValidate(Transport transport,
                                      long messageId,
                                      short opRespCode)

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

checkForErrorsInResponseStatus

protected void checkForErrorsInResponseStatus(short status,
                                              long messageId,
                                              Transport transport)