public class KeyValueMessageHandler
extends com.couchbase.client.core.deps.io.netty.channel.ChannelDuplexHandler
Constructor and Description |
---|
KeyValueMessageHandler(BaseEndpoint endpoint,
EndpointContext endpointContext,
Optional<String> bucketName)
Creates a new
KeyValueMessageHandler . |
Modifier and Type | Method and Description |
---|---|
void |
channelActive(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx)
Actions to be performed when the channel becomes active.
|
void |
channelInactive(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx) |
void |
channelRead(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
void |
write(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx,
Object msg,
com.couchbase.client.core.deps.io.netty.channel.ChannelPromise promise) |
bind, close, connect, deregister, disconnect, flush, read
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
public KeyValueMessageHandler(BaseEndpoint endpoint, EndpointContext endpointContext, Optional<String> bucketName)
KeyValueMessageHandler
.endpointContext
- the parent core context.public void channelActive(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx)
Since the opaque is incremented in the handler below during bootstrap but now is only modified in this handler, cache the reference since the attribute lookup is more costly.
channelActive
in interface com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandler
channelActive
in class com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandlerAdapter
ctx
- the channel context.public void write(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx, Object msg, com.couchbase.client.core.deps.io.netty.channel.ChannelPromise promise)
write
in interface com.couchbase.client.core.deps.io.netty.channel.ChannelOutboundHandler
write
in class com.couchbase.client.core.deps.io.netty.channel.ChannelDuplexHandler
public void channelRead(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx, Object msg)
channelRead
in interface com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandler
channelRead
in class com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandlerAdapter
public void channelInactive(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx)
channelInactive
in interface com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandler
channelInactive
in class com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandlerAdapter
Copyright © 2024 Couchbase, Inc.. All rights reserved.