public abstract class AbstractCouchbaseRequest extends Object implements CouchbaseRequest
Default implementation for a CouchbaseRequest
, should be extended by child messages.
Modifier | Constructor and Description |
---|---|
protected |
AbstractCouchbaseRequest(String bucket,
String password)
Create a new
AbstractCouchbaseRequest . |
protected |
AbstractCouchbaseRequest(String bucket,
String username,
String password)
Create a new
AbstractCouchbaseRequest . |
protected |
AbstractCouchbaseRequest(String bucket,
String username,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Create a new
AbstractCouchbaseRequest . |
Modifier and Type | Method and Description |
---|---|
String |
bucket()
The associated bucket name for this request.
|
long |
creationTime()
Returns the time in nanoseconds when the message was created.
|
String |
dispatchHostname() |
void |
dispatchHostname(String hostname) |
int |
incrementRetryCount()
Returns the old retry count and increments it by one.
|
boolean |
isActive()
Checks if the request is unsubscribed on a timeout
|
long |
maxRetryDuration()
Returns the maximum retry duration for the request.
|
void |
maxRetryDuration(long maxRetryDuration)
Sets the maximum retry duration for the request.
|
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> |
observable()
Get the underlying
Observable . |
String |
password()
The password associated with the bucket/ user
|
long |
retryAfter()
Gets the initial retry after time for the request.
|
void |
retryAfter(long after)
Sets the initial retry after time for the request.
|
int |
retryCount()
Returns the current retry count.
|
Delay |
retryDelay()
Returns the retry delay config
|
void |
retryDelay(Delay retryDelay)
Sets the retry delay config
|
void |
subscriber(rx.Subscriber subscriber)
Optionally add subscriber to check for the timeouts
|
String |
toString() |
String |
username()
User authorized for bucket access
|
protected AbstractCouchbaseRequest(String bucket, String password)
Create a new AbstractCouchbaseRequest
.
Depending on the type of operation, bucket and password may be null, this needs to be enforced properly by the child implementations.
This constructor will create a AsyncSubject, which implies that the response for this request only emits one message. If you need to expose a streaming response, use the other constructor and feed it a ReplaySubject or something similar.
bucket
- the name of the bucket.password
- user password.protected AbstractCouchbaseRequest(String bucket, String username, String password)
Create a new AbstractCouchbaseRequest
.
Depending on the type of operation, bucket and password may be null, this needs to be enforced properly by the child implementations.
This constructor will create a AsyncSubject, which implies that the response for this request only emits one message. If you need to expose a streaming response, use the other constructor and feed it a ReplaySubject or something similar.
bucket
- the name of the bucket.username
- user authorized to access the bucket.password
- user password.protected AbstractCouchbaseRequest(String bucket, String username, String password, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Create a new AbstractCouchbaseRequest
.
Depending on the type of operation, bucket and password may be null, this needs to be enforced properly by the child implementations.
bucket
- the name of the bucket.username
- user authorized to access the bucket.password
- the password of the bucket.public rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable()
CouchbaseRequest
Get the underlying Observable
.
observable
in interface CouchbaseRequest
public String bucket()
CouchbaseRequest
The associated bucket name for this request.
bucket
in interface CouchbaseRequest
public String username()
CouchbaseRequest
User authorized for bucket access
username
in interface CouchbaseRequest
public String password()
CouchbaseRequest
The password associated with the bucket/ user
password
in interface CouchbaseRequest
public long creationTime()
CouchbaseMessage
Returns the time in nanoseconds when the message was created.
creationTime
in interface CouchbaseMessage
public int incrementRetryCount()
CouchbaseRequest
Returns the old retry count and increments it by one.
incrementRetryCount
in interface CouchbaseRequest
public int retryCount()
CouchbaseRequest
Returns the current retry count.
retryCount
in interface CouchbaseRequest
public void retryAfter(long after)
CouchbaseRequest
Sets the initial retry after time for the request.
retryAfter
in interface CouchbaseRequest
public long retryAfter()
CouchbaseRequest
Gets the initial retry after time for the request.
retryAfter
in interface CouchbaseRequest
public void maxRetryDuration(long maxRetryDuration)
CouchbaseRequest
Sets the maximum retry duration for the request.
maxRetryDuration
in interface CouchbaseRequest
public long maxRetryDuration()
CouchbaseRequest
Returns the maximum retry duration for the request.
maxRetryDuration
in interface CouchbaseRequest
public void retryDelay(Delay retryDelay)
CouchbaseRequest
Sets the retry delay config
retryDelay
in interface CouchbaseRequest
public Delay retryDelay()
CouchbaseRequest
Returns the retry delay config
retryDelay
in interface CouchbaseRequest
public boolean isActive()
CouchbaseRequest
Checks if the request is unsubscribed on a timeout
isActive
in interface CouchbaseRequest
public void subscriber(rx.Subscriber subscriber)
CouchbaseRequest
Optionally add subscriber to check for the timeouts
subscriber
in interface CouchbaseRequest
public String dispatchHostname()
dispatchHostname
in interface CouchbaseRequest
public void dispatchHostname(String hostname)
dispatchHostname
in interface CouchbaseRequest
Copyright © 2017 Couchbase, Inc.. All rights reserved.