public class DCPConnectionHandler extends SimpleChannelInboundHandler<FullBinaryMemcacheResponse> implements ChannelOutboundHandler
DCP connection handler makes sure that all channels have DCP connection initialized.
ChannelHandler.Sharable
Constructor and Description |
---|
DCPConnectionHandler(CoreEnvironment env)
Creates a new
DCPConnectionHandler . |
Modifier and Type | Method and Description |
---|---|
void |
bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
channelActive(ChannelHandlerContext ctx)
Once the channel is marked as active, the open DCP connection.
|
protected void |
channelRead0(ChannelHandlerContext ctx,
FullBinaryMemcacheResponse msg)
Dispatches incoming OPEN_CONNECTION responses and also initialize flow control.
|
void |
close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
flush(ChannelHandlerContext ctx) |
void |
read(ChannelHandlerContext ctx) |
void |
write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
acceptInboundMessage, channelRead
channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
exceptionCaught, handlerAdded, handlerRemoved
public DCPConnectionHandler(CoreEnvironment env)
Creates a new DCPConnectionHandler
.
public void channelActive(ChannelHandlerContext ctx) throws Exception
Once the channel is marked as active, the open DCP connection.
channelActive
in interface ChannelInboundHandler
channelActive
in class ChannelInboundHandlerAdapter
ctx
- the handler context.Exception
- if something goes wrong.protected void channelRead0(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg) throws Exception
Dispatches incoming OPEN_CONNECTION responses and also initialize flow control.
channelRead0
in class SimpleChannelInboundHandler<FullBinaryMemcacheResponse>
ctx
- the handler context.msg
- the incoming message to investigate.Exception
- if something goes wrong during negotiation.public void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) throws Exception
bind
in interface ChannelOutboundHandler
Exception
public void connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) throws Exception
connect
in interface ChannelOutboundHandler
Exception
public void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception
disconnect
in interface ChannelOutboundHandler
Exception
public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception
close
in interface ChannelOutboundHandler
Exception
public void deregister(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception
deregister
in interface ChannelOutboundHandler
Exception
public void read(ChannelHandlerContext ctx) throws Exception
read
in interface ChannelOutboundHandler
Exception
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception
write
in interface ChannelOutboundHandler
Exception
public void flush(ChannelHandlerContext ctx) throws Exception
flush
in interface ChannelOutboundHandler
Exception
Copyright © 2017 Couchbase, Inc.. All rights reserved.