org.jclouds.gae
Class AsyncGaeHttpCommandExecutorService

java.lang.Object
  extended by 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


Copyright © 2009-2012 jclouds. All Rights Reserved.