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
Modifier and Type Method Description void
bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise)
void
channelActive(ChannelHandlerContext ctx)
Once the channel is marked as active, select bucket command is sent if the HELLO request has SELECT_BUCKET feature enabled.protected void
channelRead0(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg)
Handles incoming Select bucket responses.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
-
KeyValueSelectBucketHandler
Creates a newKeyValueSelectBucketHandler
.- Parameters:
bucket
- the name of the user/bucket.
-
-
Method Details
-
channelActive
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 ExceptionHandles 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
- 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
- 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
-