public class HotRodDecoder extends AbstractProtocolDecoder<byte[],byte[]> implements Constants
Constructor and Description |
---|
HotRodDecoder(EmbeddedCacheManager cacheManager,
NettyTransport transport,
HotRodServer server) |
Modifier and Type | Method and Description |
---|---|
Object |
createErrorResponse(Throwable t) |
Object |
createGetResponse(byte[] k,
CacheEntry entry) |
protected HotRodHeader |
createHeader() |
Object |
createMultiGetResponse(scala.collection.immutable.Map<byte[],CacheEntry> pairs) |
Object |
createNotExecutedResponse(byte[] prev) |
Object |
createNotExistResponse() |
protected scala.Tuple2<HotRodException,Object> |
createServerException(Exception e,
io.netty.buffer.ByteBuf b) |
Object |
createStatsResponse() |
Object |
createSuccessResponse(byte[] prev) |
byte[] |
createValue() |
protected Object |
customDecodeHeader(io.netty.channel.Channel ch,
io.netty.buffer.ByteBuf buffer) |
protected Object |
customDecodeKey(io.netty.channel.Channel ch,
io.netty.buffer.ByteBuf buffer) |
protected Object |
customDecodeValue(io.netty.channel.Channel ch,
io.netty.buffer.ByteBuf buffer) |
Cache<byte[],byte[]> |
getCache() |
protected AdvancedCache<byte[],byte[]> |
getOptimizedCache(AdvancedCache<byte[],byte[]> c) |
scala.Option<Object> |
readHeader(io.netty.buffer.ByteBuf buffer,
HotRodHeader header) |
scala.Tuple2<byte[],Object> |
readKey(io.netty.buffer.ByteBuf b)
Returns the key read along with a boolean indicating whether the
end of the operation was found or not.
|
boolean |
readParameters(io.netty.channel.Channel ch,
io.netty.buffer.ByteBuf b) |
protected void |
readValue(io.netty.buffer.ByteBuf b) |
bind, buildMetadata, cache, channelActive, channelRead, checkpointTo, close, connect, decode, defaultLifespanTime, defaultMaxIdleTime, deregister, disconnect, exceptionCaught, flush, generateVersion, get, handleModification, header, key, params, rawValue, read, readHeader, toMillis, write, writeResponse
callDecode, channelInactive, checkpoint, checkpoint, state, state
actualReadableBytes, channelReadComplete, decodeLast, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setSingleDecode
channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
DEFAULT_HASH_FUNCTION_VERSION, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INTELLIGENCE_BASIC, INTELLIGENCE_HASH_DISTRIBUTION_AWARE, INTELLIGENCE_TOPOLOGY_AWARE, MAGIC_REQ, MAGIC_RES, VERSION_10, VERSION_11, VERSION_12, VERSION_13
EXPIRATION_DEFAULT, EXPIRATION_NONE
debug, debug, debug, debug, debug, debugf, error, info, info, isDebugEnabled, isTraceEnabled, log, logChannelStillBound, logChannelStillConnected, logErrorBeforeReadingRequest, logExceptionReported, logPostingShutdownRequest, logServerDidNotClose, logServerDidNotUnbind, logSettingMasterThreadsNotSupported, logStartWithArgs, trace, trace, trace, trace, tracef, warn
public HotRodDecoder(EmbeddedCacheManager cacheManager, NettyTransport transport, HotRodServer server)
protected HotRodHeader createHeader()
createHeader
in class AbstractProtocolDecoder<byte[],byte[]>
public scala.Option<Object> readHeader(io.netty.buffer.ByteBuf buffer, HotRodHeader header)
public Cache<byte[],byte[]> getCache()
getCache
in class AbstractProtocolDecoder<byte[],byte[]>
public scala.Tuple2<byte[],Object> readKey(io.netty.buffer.ByteBuf b)
AbstractProtocolDecoder
readKey
in class AbstractProtocolDecoder<byte[],byte[]>
public boolean readParameters(io.netty.channel.Channel ch, io.netty.buffer.ByteBuf b)
readParameters
in class AbstractProtocolDecoder<byte[],byte[]>
protected void readValue(io.netty.buffer.ByteBuf b)
readValue
in class AbstractProtocolDecoder<byte[],byte[]>
public byte[] createValue()
createValue
in class AbstractProtocolDecoder<byte[],byte[]>
public Object createSuccessResponse(byte[] prev)
createSuccessResponse
in class AbstractProtocolDecoder<byte[],byte[]>
public Object createNotExecutedResponse(byte[] prev)
createNotExecutedResponse
in class AbstractProtocolDecoder<byte[],byte[]>
public Object createNotExistResponse()
createNotExistResponse
in class AbstractProtocolDecoder<byte[],byte[]>
public Object createGetResponse(byte[] k, CacheEntry entry)
createGetResponse
in class AbstractProtocolDecoder<byte[],byte[]>
public Object createMultiGetResponse(scala.collection.immutable.Map<byte[],CacheEntry> pairs)
createMultiGetResponse
in class AbstractProtocolDecoder<byte[],byte[]>
protected Object customDecodeHeader(io.netty.channel.Channel ch, io.netty.buffer.ByteBuf buffer)
customDecodeHeader
in class AbstractProtocolDecoder<byte[],byte[]>
protected Object customDecodeKey(io.netty.channel.Channel ch, io.netty.buffer.ByteBuf buffer)
customDecodeKey
in class AbstractProtocolDecoder<byte[],byte[]>
protected Object customDecodeValue(io.netty.channel.Channel ch, io.netty.buffer.ByteBuf buffer)
customDecodeValue
in class AbstractProtocolDecoder<byte[],byte[]>
public Object createStatsResponse()
createStatsResponse
in class AbstractProtocolDecoder<byte[],byte[]>
public Object createErrorResponse(Throwable t)
createErrorResponse
in class AbstractProtocolDecoder<byte[],byte[]>
protected AdvancedCache<byte[],byte[]> getOptimizedCache(AdvancedCache<byte[],byte[]> c)
getOptimizedCache
in class AbstractProtocolDecoder<byte[],byte[]>
protected scala.Tuple2<HotRodException,Object> createServerException(Exception e, io.netty.buffer.ByteBuf b)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.