com.amazonaws.services.dynamodbv2.nio.http

Class AmazonFuture<T>

java.lang.Object

com.amazonaws.services.dynamodbv2.nio.http.AmazonFuture<T>

All Implemented Interfaces:

Future<T>

public class AmazonFuture<T>
extends Object
implements Future<T>

Created by amiroshn

Field Summary

Fields

Modifier and Type	Field and Description
private ResultHandler<T>	asyncHandler
private AmazonHttpClient.ExecOneRequestParams	execOneParams
private Future<org.apache.http.HttpResponse>	innerFuture
private com.amazonaws.Request<?>	request
private List<com.amazonaws.handlers.RequestHandler2>	requestHandlers
private com.amazonaws.http.HttpResponseHandler<com.amazonaws.AmazonWebServiceResponse<T>>	responseHandler

Constructor Summary

Constructors

Constructor and Description
AmazonFuture(com.amazonaws.Request<?> request, AmazonHttpClient.ExecOneRequestParams execOneParams, com.amazonaws.http.HttpResponseHandler<com.amazonaws.AmazonWebServiceResponse<T>> responseHandler, List<com.amazonaws.handlers.RequestHandler2> requestHandlers, ResultHandler<T> asyncHandler)

Method Summary

Modifier and Type	Method and Description
private com.amazonaws.http.HttpResponse	beforeUnmarshalling(List<com.amazonaws.handlers.RequestHandler2> requestHandler2s, com.amazonaws.Request<?> request, com.amazonaws.http.HttpResponse origHttpResponse) Run RequestHandler2.beforeUnmarshalling(com.amazonaws.Request, com.amazonaws.http.HttpResponse) callback
boolean	cancel()
boolean	cancel(boolean mayInterruptIfRunning)
private T	convert(org.apache.http.HttpResponse response)
private com.amazonaws.http.HttpResponse	createResponse(org.apache.http.client.methods.HttpRequestBase method, com.amazonaws.Request<?> request, org.apache.http.HttpResponse apacheHttpResponse)
T	get()
T	get(long timeout, TimeUnit unit)
void	handleError(Exception exception)
private T	handleResponse(com.amazonaws.Request<?> request, com.amazonaws.http.HttpResponseHandler<com.amazonaws.AmazonWebServiceResponse<T>> responseHandler, com.amazonaws.http.HttpResponse httpResponse, List<com.amazonaws.handlers.RequestHandler2> requestHandlers)
void	handleSuccess()
boolean	isCancelled()
boolean	isDone()
private boolean	isRequestSuccessful(org.apache.http.HttpResponse response)
void	setInnerFuture(Future<org.apache.http.HttpResponse> innerFuture)
private boolean	shouldBufferHttpEntity(boolean needsConnectionLeftOpen, AmazonHttpClient.ExecOneRequestParams execParams)

Methods inherited from class java.lang.Object

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

Field Detail

innerFuture

private Future<org.apache.http.HttpResponse> innerFuture

requestHandlers

private List<com.amazonaws.handlers.RequestHandler2> requestHandlers

responseHandler

private com.amazonaws.http.HttpResponseHandler<com.amazonaws.AmazonWebServiceResponse<T>> responseHandler

execOneParams

private AmazonHttpClient.ExecOneRequestParams execOneParams

request

private com.amazonaws.Request<?> request

asyncHandler

private ResultHandler<T> asyncHandler

Constructor Detail

AmazonFuture

public AmazonFuture(com.amazonaws.Request<?> request,
                    AmazonHttpClient.ExecOneRequestParams execOneParams,
                    com.amazonaws.http.HttpResponseHandler<com.amazonaws.AmazonWebServiceResponse<T>> responseHandler,
                    List<com.amazonaws.handlers.RequestHandler2> requestHandlers,
                    ResultHandler<T> asyncHandler)

Method Detail

setInnerFuture

public void setInnerFuture(Future<org.apache.http.HttpResponse> innerFuture)

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

get

public T get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

public T get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

cancel

public boolean cancel()

handleSuccess

public void handleSuccess()

handleError

public void handleError(Exception exception)

convert

private T convert(org.apache.http.HttpResponse response)
           throws ExecutionException,
                  InterruptedException

Throws:

ExecutionException

InterruptedException

shouldBufferHttpEntity

private boolean shouldBufferHttpEntity(boolean needsConnectionLeftOpen,
                                       AmazonHttpClient.ExecOneRequestParams execParams)

Returns:

True if the HttpEntity should be wrapped in a BufferedHttpEntity

isRequestSuccessful

private boolean isRequestSuccessful(org.apache.http.HttpResponse response)

beforeUnmarshalling

private com.amazonaws.http.HttpResponse beforeUnmarshalling(List<com.amazonaws.handlers.RequestHandler2> requestHandler2s,
                                                            com.amazonaws.Request<?> request,
                                                            com.amazonaws.http.HttpResponse origHttpResponse)

Run RequestHandler2.beforeUnmarshalling(com.amazonaws.Request, com.amazonaws.http.HttpResponse) callback

Parameters:

requestHandler2s - List of request handlers to invoke

request - Original request

origHttpResponse - Original HttpResponse

Returns:

HttpResponse object to pass to unmarshaller. May have been modified or replaced by the request handlers

createResponse

private com.amazonaws.http.HttpResponse createResponse(org.apache.http.client.methods.HttpRequestBase method,
                                                       com.amazonaws.Request<?> request,
                                                       org.apache.http.HttpResponse apacheHttpResponse)
                                                throws IOException

Throws:

IOException

handleResponse

private T handleResponse(com.amazonaws.Request<?> request,
                         com.amazonaws.http.HttpResponseHandler<com.amazonaws.AmazonWebServiceResponse<T>> responseHandler,
                         com.amazonaws.http.HttpResponse httpResponse,
                         List<com.amazonaws.handlers.RequestHandler2> requestHandlers)
                  throws ExecutionException

Throws:

ExecutionException