Class KeyValueErrorMapHandler
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.channel.SimpleChannelInboundHandler<FullBinaryMemcacheResponse>
-
- com.couchbase.client.core.endpoint.kv.KeyValueErrorMapHandler
-
- All Implemented Interfaces:
ChannelHandler
,ChannelInboundHandler
,ChannelOutboundHandler
public class KeyValueErrorMapHandler extends SimpleChannelInboundHandler<FullBinaryMemcacheResponse> implements ChannelOutboundHandler
This handler is added dynamically by theKeyValueFeatureHandler
to load and store the extended error map from the server. It will only be added if the server has this feature enabled.- Since:
- 1.4.4
- Author:
- Michael Nitschinger
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
ChannelHandler.Sharable
-
-
Constructor Summary
Constructors Constructor Description KeyValueErrorMapHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise)
void
channelActive(ChannelHandlerContext ctx)
protected void
channelRead0(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg)
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
userEventTriggered(ChannelHandlerContext ctx, Object evt)
void
write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
-
Methods inherited from class io.netty.channel.SimpleChannelInboundHandler
acceptInboundMessage, channelRead
-
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
-
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded, handlerRemoved
-
-
-
-
Method Detail
-
channelRead0
protected void channelRead0(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg) throws Exception
- Specified by:
channelRead0
in classSimpleChannelInboundHandler<FullBinaryMemcacheResponse>
- Throws:
Exception
-
channelActive
public void channelActive(ChannelHandlerContext ctx) throws Exception
- Specified by:
channelActive
in interfaceChannelInboundHandler
- Overrides:
channelActive
in classChannelInboundHandlerAdapter
- Throws:
Exception
-
connect
public void connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) throws Exception
- Specified by:
connect
in interfaceChannelOutboundHandler
- Throws:
Exception
-
userEventTriggered
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception
- Specified by:
userEventTriggered
in interfaceChannelInboundHandler
- Overrides:
userEventTriggered
in classChannelInboundHandlerAdapter
- Throws:
Exception
-
disconnect
public void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception
- Specified by:
disconnect
in interfaceChannelOutboundHandler
- Throws:
Exception
-
close
public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception
- Specified by:
close
in interfaceChannelOutboundHandler
- Throws:
Exception
-
deregister
public void deregister(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception
- Specified by:
deregister
in interfaceChannelOutboundHandler
- Throws:
Exception
-
read
public void read(ChannelHandlerContext ctx) throws Exception
- Specified by:
read
in interfaceChannelOutboundHandler
- Throws:
Exception
-
write
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception
- Specified by:
write
in interfaceChannelOutboundHandler
- Throws:
Exception
-
flush
public void flush(ChannelHandlerContext ctx) throws Exception
- Specified by:
flush
in interfaceChannelOutboundHandler
- Throws:
Exception
-
bind
public void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) throws Exception
- Specified by:
bind
in interfaceChannelOutboundHandler
- Throws:
Exception
-
-