class LeaseRequest<T,C,E extends PoolEntry<T,C>> extends java.lang.Object implements Cancellable
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.util.concurrent.atomic.AtomicReference<SessionRequest> |
sessionRequestRef |
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 |
attachSessionRequest(SessionRequest sessionRequest) |
boolean |
cancel() |
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.AtomicReference<SessionRequest> sessionRequestRef
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 attachSessionRequest(SessionRequest sessionRequest)
public boolean cancel()
cancel
in interface Cancellable
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