class LeaseRequest<T,C,E extends PoolEntry<T,C>> extends Object implements Cancellable
Modifier and Type | Field and Description |
---|---|
private AtomicBoolean |
completed |
private long |
connectTimeout |
private long |
deadline |
private Exception |
ex |
private BasicFuture<E> |
future |
private E |
result |
private T |
route |
private AtomicReference<SessionRequest> |
sessionRequestRef |
private Object |
state |
Constructor and Description |
---|
LeaseRequest(T route,
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(Exception ex) |
long |
getConnectTimeout() |
long |
getDeadline() |
Exception |
getException() |
BasicFuture<E> |
getFuture() |
E |
getResult() |
T |
getRoute() |
Object |
getState() |
boolean |
isDone() |
String |
toString() |
private final long connectTimeout
private final long deadline
private final AtomicReference<SessionRequest> sessionRequestRef
private final AtomicBoolean completed
public LeaseRequest(T route, 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 long getConnectTimeout()
public long getDeadline()
public boolean isDone()
public void attachSessionRequest(SessionRequest sessionRequest)
public boolean cancel()
cancel
in interface Cancellable
public BasicFuture<E> getFuture()
public Exception getException()
WebARTS Library Licensed Under the GNU - General Public License. Other Libraries licensed under their respective Open Source Licenses