public abstract class AbstractReadRequest<M> extends java.lang.Object implements Request<M>
Modifier and Type | Field and Description |
---|---|
protected java.util.List<? extends ReadItem> |
items |
protected int |
timeout |
Modifier | Constructor and Description |
---|---|
protected |
AbstractReadRequest(java.util.List<? extends ReadItem> items,
int timeout) |
Modifier and Type | Method and Description |
---|---|
void |
fail(FailureType type,
DriverState state,
java.lang.Exception ex)
Called if the response to the most recently created message is not going to be received.
|
RequestPriority |
getPriority()
Returns the
RequestPriority of this request. |
int |
getTimeout()
Returns the amount of time (in milliseconds) that this request should be given to run, before it is failed out
for a timeout.
|
boolean |
isRetryAllowed() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getKey, receiveMessage, sendMessage
protected java.util.List<? extends ReadItem> items
protected int timeout
protected AbstractReadRequest(java.util.List<? extends ReadItem> items, int timeout)
public void fail(FailureType type, DriverState state, java.lang.Exception ex)
Request
public boolean isRetryAllowed()
isRetryAllowed
in interface Request<M>
true
if retrying is allowed if Request.sendMessage()
returns false
.public int getTimeout()
Request
getTimeout
in interface Request<M>
public RequestPriority getPriority()
Request
RequestPriority
of this request.getPriority
in interface Request<M>
RequestPriority
of this request.