Package org.apache.storm.pacemaker.codec

# Class ThriftDecoder

java.lang.Object
org.apache.storm.shade.io.netty.channel.ChannelHandlerAdapter
org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapter
org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder
org.apache.storm.pacemaker.codec.ThriftDecoder

All Implemented Interfaces:
  `org.apache.storm.shade.io.netty.channel.ChannelHandler`, `org.apache.storm.shade.io.netty.channel.ChannelInboundHandler`

public class ThriftDecoder extends org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder

- ## Nested Class Summary

  ## Nested classes/interfaces inherited from class org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder

  `org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder.Cumulator`

  ## Nested classes/interfaces inherited from interface org.apache.storm.shade.io.netty.channel.ChannelHandler

  `org.apache.storm.shade.io.netty.channel.ChannelHandler.Sharable`

- ## Field Summary

  ### Fields inherited from class org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder

  `COMPOSITE_CUMULATOR, MERGE_CUMULATOR`

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `ThriftDecoder(int maxLengthBytes)`
  Instantiate a ThriftDecoder that accepts serialized messages of at most maxLength bytes.

- ## Method Summary

  Modifier and Type
  Method
  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)`

  ### Methods inherited from class org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder

  `actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered`

  ### Methods inherited from class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapter

  `channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught`

  ### Methods inherited from class org.apache.storm.shade.io.netty.channel.ChannelHandlerAdapter

  `ensureNotSharable, handlerAdded, isSharable`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

  ### Methods inherited from interface org.apache.storm.shade.io.netty.channel.ChannelHandler

  `handlerAdded`

- ## Constructor Details

  - ### ThriftDecoder

    public ThriftDecoder(int maxLengthBytes)
    Instantiate a ThriftDecoder that accepts serialized messages of at most maxLength bytes.

- ## Method Details

  - ### decode

    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
    Specified by:
      `decode` in class `org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder`
    Throws:
      `Exception`