public class MessageDecoder
extends org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder
| Constructor and Description |
|---|
MessageDecoder(KryoValuesDeserializer deser) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
decode(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
org.apache.storm.shade.io.netty.buffer.ByteBuf buf,
List<Object> out) |
void |
exceptionCaught(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggeredchannelActive, channelRegistered, channelUnregistered, channelWritabilityChangedensureNotSharable, handlerAdded, isSharablepublic MessageDecoder(KryoValuesDeserializer deser)
protected void decode(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
org.apache.storm.shade.io.netty.buffer.ByteBuf buf,
List<Object> out)
throws Exception
decode in class org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoderExceptionpublic void exceptionCaught(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
Throwable cause)
exceptionCaught in interface org.apache.storm.shade.io.netty.channel.ChannelHandlerexceptionCaught in interface org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerexceptionCaught in class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapterCopyright © 2021 The Apache Software Foundation. All rights reserved.