@UnstableApi public class RedisEncoder extends MessageToMessageEncoder<RedisMessage>
ChannelHandler.Sharable
Constructor and Description |
---|
RedisEncoder()
使用默认值
messagePool 创建一个新实例。
|
RedisEncoder(RedisMessagePool messagePool)
创建一个新的实例。
|
Modifier and Type | Method and Description |
---|---|
protected void |
encode(ChannelHandlerContext ctx, RedisMessage msg, java.util.List<java.lang.Object> out)
从一条消息编码到另一条消息。
|
acceptOutboundMessage, write
bind, close, connect, deregister, disconnect, flush, read
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
exceptionCaught, handlerAdded, handlerRemoved
public RedisEncoder()
messagePool
创建一个新实例。
public RedisEncoder(RedisMessagePool messagePool)
messagePool
- 预定义的消息池。
protected void encode(ChannelHandlerContext ctx, RedisMessage msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageEncoder
encode
在课堂上
MessageToMessageEncoder<RedisMessage>
ctx
- 这MessageToMessageEncoder
属于的ChannelHandlerContext
msg
- 要编码到另一个的消息
out
- 应该添加编码味精的
List
需要做某种聚合
java.lang.Exception
- 发生错误时抛出
Copyright © 2008–2018 The Netty Project. All rights reserved.