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

Class RntbdClientChannelHandler

  • All Implemented Interfaces:
    io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.pool.ChannelPoolHandler
    public class RntbdClientChannelHandler
extends io.netty.channel.ChannelInitializer<io.netty.channel.Channel>
implements io.netty.channel.pool.ChannelPoolHandler

    • Nested Class Summary

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

        io.netty.channel.ChannelHandler.Sharable

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void channelAcquired​(io.netty.channel.Channel channel)
      Called by ChannelPool.acquire() after a Channel is acquired
      void channelCreated​(io.netty.channel.Channel channel)
      Called by ChannelPool.release(io.netty.channel.Channel) after a Channel is created
      void channelReleased​(io.netty.channel.Channel channel)
      Called by ChannelPool.release(io.netty.channel.Channel) after a Channel is released
      protected void initChannel​(io.netty.channel.Channel channel)
      Called by @{ChannelPipeline} initializer after the current channel is registered to an event loop.

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

        channelRegistered, exceptionCaught, handlerAdded, handlerRemoved

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

        channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

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

        ensureNotSharable, isSharable

    • Method Detail

      • channelAcquired

        public void channelAcquired​(io.netty.channel.Channel channel)
        Called by ChannelPool.acquire() after a Channel is acquired

        This method is called within the EventLoop of the Channel.

        Specified by:
        channelAcquired in interface io.netty.channel.pool.ChannelPoolHandler
        Parameters:
        channel - a channel that was just acquired

      • channelCreated

        public void channelCreated​(io.netty.channel.Channel channel)
        Called by ChannelPool.release(io.netty.channel.Channel) after a Channel is created

        This method is called within the EventLoop of the Channel.

        Specified by:
        channelCreated in interface io.netty.channel.pool.ChannelPoolHandler
        Parameters:
        channel - a channel that was just created

      • channelReleased

        public void channelReleased​(io.netty.channel.Channel channel)
        Called by ChannelPool.release(io.netty.channel.Channel) after a Channel is released

        This method is called within the EventLoop of the Channel.

        Specified by:
        channelReleased in interface io.netty.channel.pool.ChannelPoolHandler
        Parameters:
        channel - a channel that was just released

      • initChannel

        protected void initChannel​(io.netty.channel.Channel channel)
        Called by @{ChannelPipeline} initializer after the current channel is registered to an event loop.

        This method constructs this pipeline: 

        
 ChannelPipeline {
     (SslHandler#0 = io.netty.handler.ssl.SslHandler),
     (IdleTimeoutHandler#0 = io.netty.handler.timeout.IdleTimeoutHandler),
     (LoggingHandler#0 = io.netty.handler.logging.LoggingHandler),  // iff RntbdClientChannelHandler.config.wireLogLevel != null
     (RntbdContextNegotiator#0 = com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextNegotiator),
     (RntbdResponseDecoder#0 = com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdResponseDecoder),
     (RntbdRequestEncoder#0 = com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestEncoder),
     (RntbdRequestManager#0 = com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdRequestManager),
 }
        Specified by:
        initChannel in class io.netty.channel.ChannelInitializer<io.netty.channel.Channel>
        Parameters:
        channel - a channel that was just registered with an event loop