class LeaseRequest<T,C,E extends PoolEntry<T,C>>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicBoolean |
completed |
private long |
connectTimeout |
private long |
deadline |
private java.lang.Exception |
ex |
private BasicFuture<E> |
future |
private E |
result |
private T |
route |
private java.lang.Object |
state |
Constructor and Description |
---|
LeaseRequest(T route,
java.lang.Object state,
long connectTimeout,
long leaseTimeout,
BasicFuture<E> future)
Contructor
|
Modifier and Type | Method and Description |
---|---|
void |
completed(E result) |
void |
failed(java.lang.Exception ex) |
long |
getConnectTimeout() |
long |
getDeadline() |
java.lang.Exception |
getException() |
BasicFuture<E> |
getFuture() |
E |
getResult() |
T |
getRoute() |
java.lang.Object |
getState() |
boolean |
isDone() |
java.lang.String |
toString() |
private final T route
private final java.lang.Object state
private final long connectTimeout
private final long deadline
private final BasicFuture<E extends PoolEntry<T,C>> future
private final java.util.concurrent.atomic.AtomicBoolean completed
private volatile java.lang.Exception ex
public LeaseRequest(T route, java.lang.Object state, long connectTimeout, long leaseTimeout, BasicFuture<E> future)
route
- routestate
- stateconnectTimeout
- http connection timeoutleaseTimeout
- timeout to wait in a request queue until kicked offfuture
- future callbackpublic T getRoute()
public java.lang.Object getState()
public long getConnectTimeout()
public long getDeadline()
public boolean isDone()
public void failed(java.lang.Exception ex)
public void completed(E result)
public BasicFuture<E> getFuture()
public E getResult()
public java.lang.Exception getException()
public java.lang.String toString()
toString
in class java.lang.Object