org.jclouds.gae

Class AsyncGaeHttpCommandExecutorService

java.lang.Object

org.jclouds.http.internal.BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>

org.jclouds.gae.AsyncGaeHttpCommandExecutorService

All Implemented Interfaces:

HttpCommandExecutorService

@Singleton
public class AsyncGaeHttpCommandExecutorService
extends BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>

Google App Engine version of HttpCommandExecutorService using their fetchAsync call

Author:

Adrian Cole

Nested Class Summary

Nested classes/interfaces inherited from class org.jclouds.http.internal.BaseHttpCommandExecutorService

BaseHttpCommandExecutorService.HttpResponseCallable

Field Summary

Fields

Modifier and Type	Field and Description
static String	USER_AGENT

Fields inherited from class org.jclouds.http.internal.BaseHttpCommandExecutorService

contentMetadataCodec, errorHandler, headerLog, ioRetryHandler, logger, retryHandler, utils, wire

Constructor Summary

Constructors

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)

Method Summary

Methods

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.

Methods inherited from class org.jclouds.http.internal.BaseHttpCommandExecutorService

consumeOnClose, invoke

Methods inherited from class java.lang.Object

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

Field Detail

USER_AGENT

public static final String USER_AGENT

Constructor Detail

AsyncGaeHttpCommandExecutorService

@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)

Method Detail

convert

protected HttpResponse convert(com.google.appengine.api.urlfetch.HTTPResponse gaeResponse)

convert

protected com.google.appengine.api.urlfetch.HTTPRequest convert(HttpRequest request)
                                                         throws IOException

Specified by:

convert in class BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>

Throws:

IOException

cleanup

protected void cleanup(com.google.appengine.api.urlfetch.HTTPRequest nativeRequest)

nothing to clean up.

Specified by:

cleanup in class BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>

invoke

protected HttpResponse invoke(com.google.appengine.api.urlfetch.HTTPRequest request)
                       throws IOException

Specified by:

invoke in class BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>

Throws:

IOException

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

Returns a potentially deferred HttpResponse from a server responding to the command. The output ListenableFuture need not be done, making HttpCommandExecutorService suitable for asynchronous derivations.

Specified by:

submit in interface HttpCommandExecutorService

Overrides:

submit in class BaseHttpCommandExecutorService<com.google.appengine.api.urlfetch.HTTPRequest>