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 the
KeyValueFeatureHandler
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
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
-
Constructor Details
-
KeyValueErrorMapHandler
public KeyValueErrorMapHandler()
-
-
Method Details
-
channelRead0
protected void channelRead0(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg) throws Exception- Specified by:
channelRead0
in classSimpleChannelInboundHandler<FullBinaryMemcacheResponse>
- Throws:
Exception
-
channelActive
- 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
- Specified by:
userEventTriggered
in interfaceChannelInboundHandler
- Overrides:
userEventTriggered
in classChannelInboundHandlerAdapter
- Throws:
Exception
-
disconnect
- Specified by:
disconnect
in interfaceChannelOutboundHandler
- Throws:
Exception
-
close
- Specified by:
close
in interfaceChannelOutboundHandler
- Throws:
Exception
-
deregister
- Specified by:
deregister
in interfaceChannelOutboundHandler
- Throws:
Exception
-
read
- Specified by:
read
in interfaceChannelOutboundHandler
- Throws:
Exception
-
write
- Specified by:
write
in interfaceChannelOutboundHandler
- Throws:
Exception
-
flush
- 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
-