@Singleton public class AsyncGaeHttpCommandExecutorService extends BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>
HttpCommandExecutorService using their
fetchAsync callBaseHttpCommandExecutorService.HttpResponseCallable| Modifier and Type | Field and Description |
|---|---|
static String |
USER_AGENT |
contentMetadataCodec, errorHandler, headerLog, ioRetryHandler, logger, retryHandler, utils, wire| Constructor and Description |
|---|
AsyncGaeHttpCommandExecutorService(com.google.appengine.api.urlfetch.URLFetchService urlFetchService,
HttpUtils utils,
ContentMetadataCodec contentMetadataCodec,
com.google.common.util.concurrent.ListeningExecutorService ioExecutor,
IOExceptionRetryHandler ioRetryHandler,
DelegatingRetryHandler retryHandler,
DelegatingErrorHandler errorHandler,
HttpWire wire,
ConvertToGaeRequest convertToGaeRequest,
ConvertToJcloudsResponse convertToJcloudsResponse) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
cleanup(com.google.appengine.api.urlfetch.HTTPRequest nativeRequest)
nothing to clean up.
|
protected com.google.appengine.api.urlfetch.HTTPRequest |
convert(HttpRequest request) |
protected HttpResponse |
convert(com.google.appengine.api.urlfetch.HTTPResponse gaeResponse) |
com.google.appengine.api.urlfetch.HTTPRequest |
filterLogAndConvertRe(HttpRequest request) |
protected HttpResponse |
invoke(com.google.appengine.api.urlfetch.HTTPRequest request) |
com.google.common.util.concurrent.ListenableFuture<HttpResponse> |
submit(HttpCommand command)
Returns a potentially deferred
HttpResponse from a server responding to the
command. |
consumeOnClose, invokepublic static final String USER_AGENT
@Inject
public AsyncGaeHttpCommandExecutorService(com.google.appengine.api.urlfetch.URLFetchService urlFetchService,
HttpUtils utils,
ContentMetadataCodec contentMetadataCodec,
@Named(value="jclouds.io-worker-threads")
com.google.common.util.concurrent.ListeningExecutorService ioExecutor,
IOExceptionRetryHandler ioRetryHandler,
DelegatingRetryHandler retryHandler,
DelegatingErrorHandler errorHandler,
HttpWire wire,
ConvertToGaeRequest convertToGaeRequest,
ConvertToJcloudsResponse convertToJcloudsResponse)
protected HttpResponse convert(com.google.appengine.api.urlfetch.HTTPResponse gaeResponse)
protected com.google.appengine.api.urlfetch.HTTPRequest convert(HttpRequest request) throws IOException
convert in class BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>IOExceptionprotected void cleanup(com.google.appengine.api.urlfetch.HTTPRequest nativeRequest)
cleanup in class BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>protected HttpResponse invoke(com.google.appengine.api.urlfetch.HTTPRequest request) throws IOException
invoke in class BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>IOExceptionpublic com.google.appengine.api.urlfetch.HTTPRequest filterLogAndConvertRe(HttpRequest request)
public com.google.common.util.concurrent.ListenableFuture<HttpResponse> submit(HttpCommand command)
HttpCommandExecutorServiceHttpResponse from a server responding to the
command. The output ListenableFuture need not be
done, making HttpCommandExecutorService
suitable for asynchronous derivations.submit in interface HttpCommandExecutorServicesubmit in class BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>Copyright © 2009-2014 The Apache Software Foundation. All Rights Reserved.