public class ApacheResponseFuture<V> extends AbstractListenableFuture<V>
| Constructor and Description | 
|---|
ApacheResponseFuture(AsyncHandler<V> asyncHandler,
                    int responseTimeoutInMs,
                    Request request,
                    org.apache.commons.httpclient.HttpMethodBase method)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
abort(Throwable t)
 | 
boolean | 
cancel(boolean mayInterruptIfRunning)  | 
void | 
content(V v)
TODO. 
 | 
void | 
done(Callable callable)
Execute a  
Callable  and if there is no exception, mark this Future as done and release the internal lock. | 
V | 
get()  | 
V | 
get(long timeout,
   TimeUnit unit)  | 
boolean | 
getAndSetWriteBody(boolean writeBody)
Write the  
Request body | 
boolean | 
getAndSetWriteHeaders(boolean writeHeaders)
Write the  
Request headers | 
Request | 
getRequest()  | 
boolean | 
hasExpired()
Is the Future still valid 
 | 
boolean | 
isCancelled()  | 
boolean | 
isDone()  | 
protected void | 
setInnerFuture(Future<V> innerFuture)  | 
protected void | 
setReaperFuture(Future<?> reaperFuture)  | 
String | 
toString()  | 
void | 
touch()
Touch the current instance to prevent external service to times out. 
 | 
addListener, donepublic ApacheResponseFuture(AsyncHandler<V> asyncHandler, int responseTimeoutInMs, Request request, org.apache.commons.httpclient.HttpMethodBase method)
public void done(Callable callable)
ListenableFutureCallable  and if there is no exception, mark this Future as done and release the internal lock.public void content(V v)
v - The new contentprotected void setReaperFuture(Future<?> reaperFuture)
public void abort(Throwable t)
ListenableFuturepublic boolean cancel(boolean mayInterruptIfRunning)
public boolean isCancelled()
public boolean isDone()
public V get() throws InterruptedException, ExecutionException
public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
public boolean hasExpired()
true if response has expired and should be terminated.public void touch()
ListenableFuturepublic Request getRequest()
public boolean getAndSetWriteHeaders(boolean writeHeaders)
Request headerspublic boolean getAndSetWriteBody(boolean writeBody)
Request bodyCopyright © 2015. All rights reserved.