Class KeyValueSelectBucketHandler
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.channel.SimpleChannelInboundHandler<FullBinaryMemcacheResponse>
-
- com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
-
- All Implemented Interfaces:
ChannelHandler
,ChannelInboundHandler
,ChannelOutboundHandler
public class KeyValueSelectBucketHandler extends SimpleChannelInboundHandler<FullBinaryMemcacheResponse> implements ChannelOutboundHandler
A Select bucket handler required for Spock cluster- Since:
- 1.4.4
- Author:
- Subhashni Balakrishnan
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
ChannelHandler.Sharable
-
-
Constructor Summary
Constructors Constructor Description KeyValueSelectBucketHandler(String bucket)
Creates a newKeyValueSelectBucketHandler
.
-
Method Summary
-
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 Detail
-
KeyValueSelectBucketHandler
public KeyValueSelectBucketHandler(String bucket)
Creates a newKeyValueSelectBucketHandler
.- Parameters:
bucket
- the name of the user/bucket.
-
-
Method Detail
-
channelActive
public void channelActive(ChannelHandlerContext ctx) throws Exception
Once the channel is marked as active, select bucket command is sent if the HELLO request has SELECT_BUCKET feature enabled.- Specified by:
channelActive
in interfaceChannelInboundHandler
- Overrides:
channelActive
in classChannelInboundHandlerAdapter
- Parameters:
ctx
- the handler context.- Throws:
Exception
- if something goes wrong during communicating to the server.
-
channelRead0
protected void channelRead0(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg) throws Exception
Handles incoming Select bucket responses.- Specified by:
channelRead0
in classSimpleChannelInboundHandler<FullBinaryMemcacheResponse>
- Parameters:
ctx
- the handler context.msg
- the incoming message to investigate.- Throws:
Exception
- if something goes wrong during communicating to the server.
-
userEventTriggered
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception
- Specified by:
userEventTriggered
in interfaceChannelInboundHandler
- Overrides:
userEventTriggered
in classChannelInboundHandlerAdapter
- Throws:
Exception
-
bind
public void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) throws Exception
- Specified by:
bind
in interfaceChannelOutboundHandler
- Throws:
Exception
-
connect
public void connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) throws Exception
- Specified by:
connect
in interfaceChannelOutboundHandler
- 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
-
-