@InterfaceStability.Experimental @InterfaceAudience.Public public class DCPConnection extends Object
DCP connection used to subscribe to DCP streams.
Constructor and Description |
---|
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password) |
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password,
SerializedSubject<DCPRequest,DCPRequest> subject) |
Modifier and Type | Method and Description |
---|---|
Observable<ResponseStatus> |
addStream(short partition) |
Observable<ResponseStatus> |
addStream(short partition,
long vbucketUUID,
long startSequenceNumber,
long endSequenceNumber,
long snapshotStartSequenceNumber,
long snapshotEndSequenceNumber) |
String |
bucket() |
void |
consumed(DCPMessage event) |
Observable<MutationToken> |
getCurrentState() |
Observable<ResponseStatus> |
removeStream(short partition) |
Subject<DCPRequest,DCPRequest> |
subject() |
public DCPConnection(CoreEnvironment env, ClusterFacade core, String bucket, String password)
public DCPConnection(CoreEnvironment env, ClusterFacade core, String bucket, String password, SerializedSubject<DCPRequest,DCPRequest> subject)
public String bucket()
public Subject<DCPRequest,DCPRequest> subject()
public Observable<ResponseStatus> addStream(short partition)
public Observable<ResponseStatus> addStream(short partition, long vbucketUUID, long startSequenceNumber, long endSequenceNumber, long snapshotStartSequenceNumber, long snapshotEndSequenceNumber)
public Observable<ResponseStatus> removeStream(short partition)
public Observable<MutationToken> getCurrentState()
public void consumed(DCPMessage event)
Copyright © 2016 Couchbase, Inc.. All rights reserved.