@UnstableApi
public final class RedisDecoder
extends io.netty.handler.codec.ByteToMessageDecoder
RedisMessage
objects following
RESP (REdis Serialization Protocol).
RedisMessage
parts can be aggregated to RedisMessage
using
RedisArrayAggregator
or processed directly.Constructor and Description |
---|
RedisDecoder()
Creates a new instance with default
maxInlineMessageLength and messagePool . |
RedisDecoder(int maxInlineMessageLength,
RedisMessagePool messagePool)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
decode(io.netty.channel.ChannelHandlerContext ctx,
io.netty.buffer.ByteBuf in,
List<Object> out) |
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
ensureNotSharable, handlerAdded, isSharable
public RedisDecoder()
maxInlineMessageLength
and messagePool
.public RedisDecoder(int maxInlineMessageLength, RedisMessagePool messagePool)
maxInlineMessageLength
- the maximum length of inline message.messagePool
- the predefined message pool.Copyright © 2008–2017 The Netty Project. All rights reserved.