Package com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

Class RntbdContextRequestDecoder

  • All Implemented Interfaces:
    io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler
    public class RntbdContextRequestDecoder
extends io.netty.handler.codec.ByteToMessageDecoder

    • Nested Class Summary

      • Nested classes/interfaces inherited from class io.netty.handler.codec.ByteToMessageDecoder

        io.netty.handler.codec.ByteToMessageDecoder.Cumulator

      • Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

        io.netty.channel.ChannelHandler.Sharable

    • Field Summary

      • Fields inherited from class io.netty.handler.codec.ByteToMessageDecoder

        COMPOSITE_CUMULATOR, MERGE_CUMULATOR

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void channelRead​(io.netty.channel.ChannelHandlerContext context, Object message)
      Prepare for decoding an @{link RntbdContextRequest} or fire a channel readTree event to pass the input message along
      protected void decode​(io.netty.channel.ChannelHandlerContext context, io.netty.buffer.ByteBuf in, List<Object> out)
      Decode an RntbdContextRequest from an ByteBuf stream

      • Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder

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

      • Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

        channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught

      • Methods inherited from class io.netty.channel.ChannelHandlerAdapter

        ensureNotSharable, handlerAdded, isSharable

      • Methods inherited from interface io.netty.channel.ChannelHandler

        handlerAdded

    • Constructor Detail

      • RntbdContextRequestDecoder

        public RntbdContextRequestDecoder()

    • Method Detail

      • channelRead

        public void channelRead​(io.netty.channel.ChannelHandlerContext context,
                        Object message)
                 throws Exception
        Prepare for decoding an @{link RntbdContextRequest} or fire a channel readTree event to pass the input message along
        Specified by:
        channelRead in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelRead in class io.netty.handler.codec.ByteToMessageDecoder
        Parameters:
        context - the ChannelHandlerContext which this ByteToMessageDecoder belongs to
        message - the message to be decoded
        Throws:
        Exception - thrown if an error occurs

      • decode

        protected void decode​(io.netty.channel.ChannelHandlerContext context,
                      io.netty.buffer.ByteBuf in,
                      List<Object> out)
               throws IllegalStateException
        Decode an RntbdContextRequest from an ByteBuf stream

        This method will be called till either an input ByteBuf has nothing to readTree on return from this method or till nothing is readTree from the input ByteBuf.

        Specified by:
        decode in class io.netty.handler.codec.ByteToMessageDecoder
        Parameters:
        context - the ChannelHandlerContext which this ByteToMessageDecoder belongs to
        in - the ByteBuf from which to readTree data
        out - the List to which decoded messages should be added
        Throws:
        IllegalStateException - thrown if an error occurs