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()
Cancels the ongoing operation or process.
|
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()
Cancellable
cancel
in interface Cancellable
true
if the operation or process has been cancelled as a result of
this method call or false
if it has already been cancelled or not started.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