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  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)

Google Analytics

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