@InterfaceStability.Experimental @InterfaceAudience.Private public abstract class AbstractDCPMessage extends AbstractDCPRequest implements DCPMessage
Default implementation of DCPRequest
.
DEFAULT_PARTITION
Constructor and Description |
---|
AbstractDCPMessage(int totalBodyLength,
short partition,
String key,
String bucket,
String password)
Creates a new
AbstractDCPMessage . |
AbstractDCPMessage(int totalBodyLength,
short partition,
String key,
String bucket,
String password,
Subject<CouchbaseResponse,CouchbaseResponse> observable) |
Modifier and Type | Method and Description |
---|---|
String |
key() |
int |
totalBodyLength() |
partition, partition, toString
bucket, creationTime, incrementRetryCount, observable, password, retryCount
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
partition
bucket, incrementRetryCount, observable, password, retryCount
creationTime
public AbstractDCPMessage(int totalBodyLength, short partition, String key, String bucket, String password)
Creates a new AbstractDCPMessage
.
totalBodyLength
- partition
- key
- bucket
- the bucket of the document.password
- the optional password of the bucket.public AbstractDCPMessage(int totalBodyLength, short partition, String key, String bucket, String password, Subject<CouchbaseResponse,CouchbaseResponse> observable)
public int totalBodyLength()
totalBodyLength
in interface DCPMessage
public String key()
key
in interface DCPMessage
Copyright © 2016 Couchbase, Inc.. All rights reserved.