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

Class RntbdContextNegotiator

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.netty.channel.CombinedChannelDuplexHandler<com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextDecoder,com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequestEncoder>

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

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler

public final class RntbdContextNegotiator
extends io.netty.channel.CombinedChannelDuplexHandler<com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextDecoder,com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequestEncoder>

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor	Description
RntbdContextNegotiator(RntbdRequestManager manager, com.microsoft.azure.cosmosdb.internal.UserAgentContainer userAgent)

Method Summary

Modifier and Type	Method	Description
void	write(io.netty.channel.ChannelHandlerContext context, Object message, io.netty.channel.ChannelPromise promise)	Called once a write operation is made.

Methods inherited from class io.netty.channel.CombinedChannelDuplexHandler

bind, channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, close, connect, deregister, disconnect, exceptionCaught, flush, handlerAdded, handlerRemoved, inboundHandler, init, outboundHandler, read, removeInboundHandler, removeOutboundHandler, 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

Constructor Detail

RntbdContextNegotiator

public RntbdContextNegotiator(RntbdRequestManager manager,
                              com.microsoft.azure.cosmosdb.internal.UserAgentContainer userAgent)

Method Detail

write

public void write(io.netty.channel.ChannelHandlerContext context,
                  Object message,
                  io.netty.channel.ChannelPromise promise)
           throws Exception

Called once a write operation is made. The write operation will write the messages through the ChannelPipeline. Those are then ready to be flushed to the actual Channel once Channel.flush() is called

Specified by:

write in interface io.netty.channel.ChannelOutboundHandler

Overrides:

write in class io.netty.channel.CombinedChannelDuplexHandler<com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextDecoder,com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdContextRequestEncoder>

Parameters:

context - the ChannelHandlerContext for which the write operation is made

message - the message to write

promise - the ChannelPromise to notify once the operation completes

Throws:

Exception - thrown if an error occurs