public class ManagerMessageHandler
extends com.couchbase.client.core.deps.io.netty.channel.ChannelDuplexHandler
Note that since one of the messages is a long streaming connection to get continuous updates on configs, the channel might be occupied for a long time. As a result, the upper layers (service pooling) need to be responsible for opening another handler if all the current ones are occupied.
Constructor and Description |
---|
ManagerMessageHandler(BaseEndpoint endpoint,
CoreContext coreContext) |
Modifier and Type | Method and Description |
---|---|
void |
channelActive(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx) |
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 |
userEventTriggered(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx,
Object evt) |
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
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
public ManagerMessageHandler(BaseEndpoint endpoint, CoreContext coreContext)
public void channelActive(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx)
channelActive
in interface com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandler
channelActive
in class com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandlerAdapter
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
public void userEventTriggered(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx, Object evt)
userEventTriggered
in interface com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandler
userEventTriggered
in class com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandlerAdapter
Copyright © 2020 Couchbase, Inc.. All rights reserved.