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

Class RntbdRequestDecoder

  • All Implemented Interfaces:
    io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler
    public final class RntbdRequestDecoder
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 RntbdRequest} 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 the input ByteBuf to an RntbdRequest instance.

      • 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

      • RntbdRequestDecoder

        public RntbdRequestDecoder()

    • Method Detail

      • channelRead

        public void channelRead​(io.netty.channel.ChannelHandlerContext context,
                        Object message)
                 throws Exception
        Prepare for decoding an @{link RntbdRequest} 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 the input ByteBuf to an RntbdRequest instance.

        This method will be called till either the input ByteBuf has nothing to readTree after return from this method or till nothing was readTree from the input ByteBuf.

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