org.infinispan.server.hotrod

Class AbstractVersionedDecoder

java.lang.Object

org.infinispan.server.hotrod.AbstractVersionedDecoder

Direct Known Subclasses:

Decoder10, Decoder10$

public abstract class AbstractVersionedDecoder
extends Object

This class represents the work to be done by a decoder of a particular Hot Rod protocol version.

Since:

4.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
AbstractVersionedDecoder()

Method Summary

Methods

Modifier and Type	Method and Description
abstract ErrorResponse	createErrorResponse(HotRodHeader header, Throwable t) Create an error response based on the Throwable instance received.
abstract Object	createGetResponse(HotRodHeader header, CacheEntry entry) Create a response for get a request.
abstract Object	createNotExecutedResponse(HotRodHeader header, byte[] prev) Create a response indicating the the operation could not be executed.
abstract Object	createNotExistResponse(HotRodHeader header) Create a response indicating that the key, which the message tried to operate on, did not exist.
abstract Object	createStatsResponse(HotRodHeader header, Stats stats, NettyTransport t) Create a response for the stats command.
abstract Object	createSuccessResponse(HotRodHeader header, byte[] prev) Create a successful response.
abstract Object	customReadHeader(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache) Handle a protocol specific header reading.
abstract Object	customReadKey(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache, scala.collection.Seq<QueryFacade> queryFacades) Handle a protocol specific key reading.
abstract Object	customReadValue(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache) Handle a protocol specific value reading.
abstract AdvancedCache<byte[],byte[]>	getOptimizedCache(HotRodHeader h, AdvancedCache<byte[],byte[]> c) Get an optimized cache instance depending on the operation parameters.
abstract boolean	readHeader(org.jboss.netty.buffer.ChannelBuffer buffer, byte version, long messageId, HotRodHeader header) Having read the message's Id, read the rest of Hot Rod header from the given buffer and return it.
abstract scala.Tuple2<byte[],Object>	readKey(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer) Read the key to operate on from the message.
abstract scala.Tuple2<RequestParameters,Object>	readParameters(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer) Read the parameters of the operation, if present.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractVersionedDecoder

public AbstractVersionedDecoder()

Method Detail

readHeader

public abstract boolean readHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
                 byte version,
                 long messageId,
                 HotRodHeader header)

Having read the message's Id, read the rest of Hot Rod header from the given buffer and return it.

readKey

public abstract scala.Tuple2<byte[],Object> readKey(HotRodHeader header,
                                  org.jboss.netty.buffer.ChannelBuffer buffer)

Read the key to operate on from the message.

readParameters

public abstract scala.Tuple2<RequestParameters,Object> readParameters(HotRodHeader header,
                                                    org.jboss.netty.buffer.ChannelBuffer buffer)

Read the parameters of the operation, if present.

createSuccessResponse

public abstract Object createSuccessResponse(HotRodHeader header,
                           byte[] prev)

Create a successful response.

createNotExecutedResponse

public abstract Object createNotExecutedResponse(HotRodHeader header,
                               byte[] prev)

Create a response indicating the the operation could not be executed.

createNotExistResponse

public abstract Object createNotExistResponse(HotRodHeader header)

Create a response indicating that the key, which the message tried to operate on, did not exist.

createGetResponse

public abstract Object createGetResponse(HotRodHeader header,
                       CacheEntry entry)

Create a response for get a request.

customReadHeader

public abstract Object customReadHeader(HotRodHeader header,
                      org.jboss.netty.buffer.ChannelBuffer buffer,
                      AdvancedCache<byte[],byte[]> cache)

Handle a protocol specific header reading.

customReadKey

public abstract Object customReadKey(HotRodHeader header,
                   org.jboss.netty.buffer.ChannelBuffer buffer,
                   AdvancedCache<byte[],byte[]> cache,
                   scala.collection.Seq<QueryFacade> queryFacades)

Handle a protocol specific key reading.

customReadValue

public abstract Object customReadValue(HotRodHeader header,
                     org.jboss.netty.buffer.ChannelBuffer buffer,
                     AdvancedCache<byte[],byte[]> cache)

Handle a protocol specific value reading.

createStatsResponse

public abstract Object createStatsResponse(HotRodHeader header,
                         Stats stats,
                         NettyTransport t)

Create a response for the stats command.

createErrorResponse

public abstract ErrorResponse createErrorResponse(HotRodHeader header,
                                Throwable t)

Create an error response based on the Throwable instance received.

getOptimizedCache

public abstract AdvancedCache<byte[],byte[]> getOptimizedCache(HotRodHeader h,
                                             AdvancedCache<byte[],byte[]> c)

Get an optimized cache instance depending on the operation parameters.