public class ThriftDecoder
extends org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder
| Constructor and Description |
|---|
ThriftDecoder(int maxLengthBytes)
Instantiate a ThriftDecoder that accepts serialized messages of at most maxLength bytes.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
decode(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext channelHandlerContext,
org.apache.storm.shade.io.netty.buffer.ByteBuf buf,
List<Object> out) |
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggeredchannelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaughtensureNotSharable, handlerAdded, isSharablepublic ThriftDecoder(int maxLengthBytes)
Instantiate a ThriftDecoder that accepts serialized messages of at most maxLength bytes.
protected void decode(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext channelHandlerContext,
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.ByteToMessageDecoderExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.