org.apache.http.nio.pool

Class LeaseRequest<T,C,E extends PoolEntry<T,C>>

java.lang.Object

org.apache.http.nio.pool.LeaseRequest<T,C,E>

class LeaseRequest<T,C,E extends PoolEntry<T,C>>
extends java.lang.Object

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
LeaseRequest(T route, java.lang.Object state, long connectTimeout, long leaseTimeout, BasicFuture<E> future) Contructor

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

route

private final T route

state

private final java.lang.Object state

connectTimeout

private final long connectTimeout

deadline

private final long deadline

future

private final BasicFuture<E extends PoolEntry<T,C>> future

completed

private final java.util.concurrent.atomic.AtomicBoolean completed

result

private volatile E extends PoolEntry<T,C> result

ex

private volatile java.lang.Exception ex

Constructor Detail

LeaseRequest

public LeaseRequest(T route,
                    java.lang.Object state,
                    long connectTimeout,
                    long leaseTimeout,
                    BasicFuture<E> future)

Contructor

Parameters:

route - route

state - state

connectTimeout - http connection timeout

leaseTimeout - timeout to wait in a request queue until kicked off

future - future callback

Method Detail

getRoute

public T getRoute()

getState

public java.lang.Object getState()

getConnectTimeout

public long getConnectTimeout()

getDeadline

public long getDeadline()

isDone

public boolean isDone()

failed

public void failed(java.lang.Exception ex)

completed

public void completed(E result)

getFuture

public BasicFuture<E> getFuture()

getResult

public E getResult()

getException

public java.lang.Exception getException()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object