public abstract class AcknowledgedRequest<Request extends MasterNodeRequest<Request>> extends MasterNodeRequest<Request> implements AckedRequest
TransportRequest.Empty
Modifier and Type | Field and Description |
---|---|
static TimeValue |
DEFAULT_ACK_TIMEOUT |
protected TimeValue |
timeout |
DEFAULT_MASTER_NODE_TIMEOUT, masterNodeTimeout
Modifier | Constructor and Description |
---|---|
protected |
AcknowledgedRequest() |
Modifier and Type | Method and Description |
---|---|
TimeValue |
ackTimeout()
Returns the acknowledgement timeout
|
void |
readFrom(StreamInput in)
Set this object's fields from a StreamInput.
|
TimeValue |
timeout()
Returns the current timeout
|
Request |
timeout(java.lang.String timeout)
Allows to set the timeout
|
Request |
timeout(TimeValue timeout)
Allows to set the timeout
|
void |
writeTo(StreamOutput out)
Write this object's fields to a StreamOutput.
|
masterNodeTimeout, masterNodeTimeout, masterNodeTimeout
getShouldStoreResult, validate
getParentTask, setParentTask
remoteAddress, remoteAddress
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
masterNodeTimeout
createTask, getDescription, setParentTask
public static final TimeValue DEFAULT_ACK_TIMEOUT
protected TimeValue timeout
public final Request timeout(java.lang.String timeout)
timeout
- timeout as a string (e.g. 1s)public final Request timeout(TimeValue timeout)
timeout
- timeout as a TimeValue
public final TimeValue timeout()
TimeValue
public TimeValue ackTimeout()
AckedRequest
ackTimeout
in interface AckedRequest
public void readFrom(StreamInput in) throws java.io.IOException
Streamable
readFrom
in interface Streamable
readFrom
in class MasterNodeRequest<Request extends MasterNodeRequest<Request>>
java.io.IOException
public void writeTo(StreamOutput out) throws java.io.IOException
Streamable
writeTo
in interface Streamable
writeTo
in class MasterNodeRequest<Request extends MasterNodeRequest<Request>>
java.io.IOException