public class ViewEndpoint extends AbstractEndpoint
This endpoint defines the pipeline for binary requests and responses.
Constructor and Description |
---|
ViewEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
ViewEndpoint . |
Modifier and Type | Method and Description |
---|---|
protected void |
customEndpointHandlers(ChannelPipeline pipeline)
Add custom endpoint handlers to the
ChannelPipeline . |
bucket, connect, disconnect, doConnect, environment, logIdent, notifyChannelInactive, password, responseBuffer, send, signalConfigReload
hasSubscribers, isState, state, states, transitionState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
hasSubscribers, isState, state, states
public ViewEndpoint(String hostname, String bucket, String password, int port, CoreEnvironment env, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new ViewEndpoint
.
hostname
- the hostname to connect on this endpoint.env
- the couchbase environment.protected void customEndpointHandlers(ChannelPipeline pipeline)
AbstractEndpoint
Add custom endpoint handlers to the ChannelPipeline
.
This method needs to be implemented by the actual endpoint implementations to add specific handlers to the pipeline depending on the endpoint type and intended behavior.
customEndpointHandlers
in class AbstractEndpoint
pipeline
- the pipeline where to add handlers.Copyright © 2015 Couchbase, Inc.. All rights reserved.