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

java.lang.Object
  extended by 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  Codec codec
           
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, 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, VERSION_10, VERSION_11
 
Constructor Summary
protected HotRodOperation(Codec codec, Flag[] flags, byte[] cacheName, AtomicInteger topologyId)
           
 
Method Summary
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


-->

Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.