public abstract class AbstractVersionedDecoder extends Object
Constructor and Description |
---|
AbstractVersionedDecoder() |
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.
|
public abstract boolean readHeader(org.jboss.netty.buffer.ChannelBuffer buffer, byte version, long messageId, HotRodHeader header)
public abstract scala.Tuple2<byte[],Object> readKey(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer)
public abstract scala.Tuple2<RequestParameters,Object> readParameters(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer)
public abstract Object createSuccessResponse(HotRodHeader header, byte[] prev)
public abstract Object createNotExecutedResponse(HotRodHeader header, byte[] prev)
public abstract Object createNotExistResponse(HotRodHeader header)
public abstract Object createGetResponse(HotRodHeader header, CacheEntry entry)
public abstract Object customReadHeader(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache)
public abstract Object customReadKey(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache, scala.collection.Seq<QueryFacade> queryFacades)
public abstract Object customReadValue(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache)
public abstract Object createStatsResponse(HotRodHeader header, Stats stats, NettyTransport t)
public abstract ErrorResponse createErrorResponse(HotRodHeader header, Throwable t)
public abstract AdvancedCache<byte[],byte[]> getOptimizedCache(HotRodHeader h, AdvancedCache<byte[],byte[]> c)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.