@InterfaceStability.Experimental @InterfaceAudience.Public @Deprecated 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)
Deprecated.
|
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password,
rx.subjects.SerializedSubject<DCPRequest,DCPRequest> subject)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
rx.Observable<ResponseStatus> |
addStream(short partition)
Deprecated.
|
rx.Observable<ResponseStatus> |
addStream(short partition,
long vbucketUUID,
long startSequenceNumber,
long endSequenceNumber,
long snapshotStartSequenceNumber,
long snapshotEndSequenceNumber)
Deprecated.
|
String |
bucket()
Deprecated.
|
void |
consumed(DCPMessage event)
Deprecated.
|
rx.Observable<MutationToken> |
getCurrentState()
Deprecated.
|
rx.Observable<ResponseStatus> |
removeStream(short partition)
Deprecated.
|
rx.subjects.Subject<DCPRequest,DCPRequest> |
subject()
Deprecated.
|
public DCPConnection(CoreEnvironment env, ClusterFacade core, String bucket, String password)
public DCPConnection(CoreEnvironment env, ClusterFacade core, String bucket, String password, rx.subjects.SerializedSubject<DCPRequest,DCPRequest> subject)
public String bucket()
public rx.subjects.Subject<DCPRequest,DCPRequest> subject()
public rx.Observable<ResponseStatus> addStream(short partition)
public rx.Observable<ResponseStatus> addStream(short partition, long vbucketUUID, long startSequenceNumber, long endSequenceNumber, long snapshotStartSequenceNumber, long snapshotEndSequenceNumber)
public rx.Observable<ResponseStatus> removeStream(short partition)
public rx.Observable<MutationToken> getCurrentState()
public void consumed(DCPMessage event)
Copyright © 2017 Couchbase, Inc.. All rights reserved.