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

Class RntbdClientChannelHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelInitializer<io.netty.channel.Channel>

com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.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

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

Methods inherited from class java.lang.Object

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

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