org.jclouds.gae
Class AsyncGaeHttpCommandExecutorService

java.lang.Object
  org.jclouds.gae.AsyncGaeHttpCommandExecutorService

All Implemented Interfaces:

HttpCommandExecutorService

@Singleton
public class AsyncGaeHttpCommandExecutorService
extends Object
implements HttpCommandExecutorService

Google App Engine version of HttpCommandExecutorService using their fetchAsync call

Author:

Adrian Cole

Field Summary

protected Logger	headerLog
protected Logger	logger
protected HttpUtils	utils
protected HttpWire	wire

Constructor Summary

AsyncGaeHttpCommandExecutorService(ExecutorService service, com.google.appengine.api.urlfetch.URLFetchService urlFetchService, ConvertToGaeRequest convertToGaeRequest, ConvertToJcloudsResponse convertToJcloudsResponse, DelegatingRetryHandler retryHandler, IOExceptionRetryHandler ioRetryHandler, DelegatingErrorHandler errorHandler, HttpUtils utils, HttpWire wire)

Method Summary

com.google.appengine.api.urlfetch.HTTPRequest	filterLogAndConvertRe(HttpRequest request)
com.google.common.util.concurrent.ListenableFuture<HttpResponse>	submit(HttpCommand command) Asks the command to build a request relevant for an endpoint that produces responses of generic type HttpResponse.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected Logger logger

headerLog

@Named(value="jclouds.headers")
protected Logger headerLog

wire

protected final HttpWire wire

utils

protected final HttpUtils utils

Constructor Detail

AsyncGaeHttpCommandExecutorService

@Inject
public AsyncGaeHttpCommandExecutorService(@Named(value="jclouds.user-threads")
                                                 ExecutorService service,
                                                 com.google.appengine.api.urlfetch.URLFetchService urlFetchService,
                                                 ConvertToGaeRequest convertToGaeRequest,
                                                 ConvertToJcloudsResponse convertToJcloudsResponse,
                                                 DelegatingRetryHandler retryHandler,
                                                 IOExceptionRetryHandler ioRetryHandler,
                                                 DelegatingErrorHandler errorHandler,
                                                 HttpUtils utils,
                                                 HttpWire wire)

Method Detail

filterLogAndConvertRe

public com.google.appengine.api.urlfetch.HTTPRequest filterLogAndConvertRe(HttpRequest request)

submit

public com.google.common.util.concurrent.ListenableFuture<HttpResponse> submit(HttpCommand command)

Description copied from interface: HttpCommandExecutorService

Asks the command to build a request relevant for an endpoint that produces responses of generic type HttpResponse. and invokes it on the endpoint, returning a future

Specified by:

submit in interface HttpCommandExecutorService

Parameters:

command - that generates requests

Returns:

Future containing the response from the endpoint