public class ConfigHandler extends AbstractGenericHandler<HttpObject,HttpRequest,ConfigRequest>
ConfigHandler
is responsible for encoding ConfigRequest
s into lower level
HttpRequest
s as well as decoding HttpObject
s into
CouchbaseResponse
s.ChannelHandler.Sharable
CHARSET, EMPTY_BYTES
Constructor and Description |
---|
ConfigHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline)
Creates a new
ConfigHandler with the default queue for requests. |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
decodeResponse(ChannelHandlerContext ctx,
HttpObject msg)
Decodes the incoming response and transforms it into a
CouchbaseResponse . |
protected HttpRequest |
encodeRequest(ChannelHandlerContext ctx,
ConfigRequest msg)
Encode the outgoing request and return it in encoded format.
|
protected void |
finishedDecoding()
Notify that decoding is finished.
|
void |
handlerRemoved(ChannelHandlerContext ctx) |
protected ServiceType |
serviceType()
Returns the
ServiceType associated with this handler. |
addHttpBasicAuth, channelActive, channelInactive, channelWritabilityChanged, completeRequestSpan, connect, createKeepAliveRequest, currentDispatchSpan, currentRequest, decode, encode, endpoint, env, exceptionCaught, getDecodingState, logIdent, onKeepAliveFired, onKeepAliveResponse, publishResponse, remoteHostname, remoteHttpHost, shouldSendKeepAlive, sideEffectRequestToCancel, userEventTriggered, write
acceptInboundMessage, acceptOutboundMessage, channelRead
bind, close, deregister, disconnect, flush, read
channelReadComplete, channelRegistered, channelUnregistered
ensureNotSharable, handlerAdded, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded
public ConfigHandler(AbstractEndpoint endpoint, com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
ConfigHandler
with the default queue for requests.endpoint
- the AbstractEndpoint
to coordinate with.responseBuffer
- the RingBuffer
to push responses into.protected HttpRequest encodeRequest(ChannelHandlerContext ctx, ConfigRequest msg) throws Exception
AbstractGenericHandler
encodeRequest
in class AbstractGenericHandler<HttpObject,HttpRequest,ConfigRequest>
ctx
- the context passed in.msg
- the outgoing message.Exception
- as a generic error.protected CouchbaseResponse decodeResponse(ChannelHandlerContext ctx, HttpObject msg) throws Exception
AbstractGenericHandler
CouchbaseResponse
.
Note that the actual notification is handled by this generic handler, the implementing class only is concerned
about the conversion itself.decodeResponse
in class AbstractGenericHandler<HttpObject,HttpRequest,ConfigRequest>
ctx
- the context passed in.msg
- the incoming message.Exception
- as a generic error. It will be bubbled up to the user (wrapped in a CouchbaseException) in the
onError of the request's Observable.protected void finishedDecoding()
AbstractGenericHandler
finishedDecoding
in class AbstractGenericHandler<HttpObject,HttpRequest,ConfigRequest>
public void handlerRemoved(ChannelHandlerContext ctx) throws Exception
handlerRemoved
in interface ChannelHandler
handlerRemoved
in class AbstractGenericHandler<HttpObject,HttpRequest,ConfigRequest>
Exception
protected ServiceType serviceType()
AbstractGenericHandler
ServiceType
associated with this handler.serviceType
in class AbstractGenericHandler<HttpObject,HttpRequest,ConfigRequest>
Copyright © 2021 Couchbase, Inc.. All rights reserved.