@ChannelHandler.Sharable
public abstract class ChunkedMessageHandler<H extends ChunkHeader,ROW extends ChunkRow,T extends ChunkTrailer,R extends ChunkedResponse<H,ROW,T>,REQ extends HttpRequest<H,ROW,T,R>>
extends com.couchbase.client.core.deps.io.netty.channel.ChannelDuplexHandler
Modifier | Constructor and Description |
---|---|
protected |
ChunkedMessageHandler(BaseEndpoint endpoint,
EndpointContext endpointContext,
ChunkResponseParser<H,ROW,T> chunkResponseParser)
Creates a new
ChunkedMessageHandler . |
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 |
handlerRemoved(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx) |
protected Optional<RetryReason> |
qualifiesForRetry(CouchbaseException exception)
Can be implemented by children to not fail a request but rather send it into retry.
|
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, isSharable
protected ChunkedMessageHandler(BaseEndpoint endpoint, EndpointContext endpointContext, ChunkResponseParser<H,ROW,T> chunkResponseParser)
ChunkedMessageHandler
.endpoint
- holds the surrounding endpoint.endpointContext
- the related endpoint context.chunkResponseParser
- the chunk response parser to use for this handler.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 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 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 handlerRemoved(com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerContext ctx)
handlerRemoved
in interface com.couchbase.client.core.deps.io.netty.channel.ChannelHandler
handlerRemoved
in class com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerAdapter
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
protected Optional<RetryReason> qualifiesForRetry(CouchbaseException exception)
exception
- the throwable to check.Copyright © 2020 Couchbase, Inc.. All rights reserved.