Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package org.infinispan.client.hotrod.impl.operations;
 
 
 
Generic Hot Rod operation. It is aware of org.infinispan.client.hotrod.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

Author(s):
Mircea.Markus@jboss.com
Since:
4.1
public abstract class HotRodOperation implements HotRodConstants {
   protected final Flag[] flags;
   public final byte[] cacheName;
   protected final AtomicInteger topologyId;
   protected final Codec codec;
   private static final byte NO_TX = 0;
   private static final byte XA_TX = 1;
   protected HotRodOperation(Codec codecFlag[] flagsbyte[] cacheNameAtomicInteger topologyId) {
      this. = flags;
      this. = cacheName;
      this. = topologyId;
      this. = codec;
   }
   public abstract Object execute();
   protected final HeaderParams writeHeader(Transport transportshort operationCode) {
      HeaderParams params = new HeaderParams()
            .opCode(operationCode).cacheName().flags()
            .topologyId().txMarker();
      return .writeHeader(transportparams);
   }

   
Magic | Message Id | Op code | Status | Topology Change Marker
   protected short readHeaderAndValidate(Transport transportHeaderParams params) {
      return .readHeader(transportparams);
   }
New to GrepCode? Check out our FAQ X