Class AnalyticsMessageHandler
java.lang.Object
com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerAdapter
com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandlerAdapter
com.couchbase.client.core.deps.io.netty.channel.ChannelDuplexHandler
com.couchbase.client.core.io.netty.chunk.ChunkedMessageHandler<AnalyticsChunkHeader,AnalyticsChunkRow,AnalyticsChunkTrailer,AnalyticsResponse,AnalyticsRequest>
com.couchbase.client.core.io.netty.analytics.AnalyticsMessageHandler
- All Implemented Interfaces:
com.couchbase.client.core.deps.io.netty.channel.ChannelHandler
,com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandler
,com.couchbase.client.core.deps.io.netty.channel.ChannelOutboundHandler
public class AnalyticsMessageHandler
extends ChunkedMessageHandler<AnalyticsChunkHeader,AnalyticsChunkRow,AnalyticsChunkTrailer,AnalyticsResponse,AnalyticsRequest>
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.couchbase.client.core.deps.io.netty.channel.ChannelHandler
com.couchbase.client.core.deps.io.netty.channel.ChannelHandler.Sharable
-
Constructor Summary
ConstructorDescriptionAnalyticsMessageHandler
(BaseEndpoint endpoint, EndpointContext endpointContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected Optional<RetryReason>
qualifiesForRetry
(CouchbaseException exception) Can be implemented by children to not fail a request but rather send it into retry.Methods inherited from class com.couchbase.client.core.io.netty.chunk.ChunkedMessageHandler
channelActive, channelInactive, channelRead, handlerRemoved, write
Methods inherited from class com.couchbase.client.core.deps.io.netty.channel.ChannelDuplexHandler
bind, close, connect, deregister, disconnect, flush, read
Methods inherited from class com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandlerAdapter
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
Methods inherited from class com.couchbase.client.core.deps.io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.couchbase.client.core.deps.io.netty.channel.ChannelHandler
handlerAdded
-
Constructor Details
-
AnalyticsMessageHandler
-
-
Method Details
-
qualifiesForRetry
Description copied from class:ChunkedMessageHandler
Can be implemented by children to not fail a request but rather send it into retry.- Overrides:
qualifiesForRetry
in classChunkedMessageHandler<AnalyticsChunkHeader,
AnalyticsChunkRow, AnalyticsChunkTrailer, AnalyticsResponse, AnalyticsRequest> - Parameters:
exception
- the throwable to check.- Returns:
- a reason if it should be retried - if empty will fail the request.
-