org.jclouds.rest.internal

Class AsyncRestClientProxy<T>

java.lang.Object

org.jclouds.rest.internal.AsyncRestClientProxy<T>

All Implemented Interfaces:

InvocationHandler

@Singleton
public class AsyncRestClientProxy<T>
extends Object
implements InvocationHandler

Generates RESTful clients from appropriately annotated interfaces.

Particularly, this code delegates calls to other things.

1. if the method has a Provides annotation, it responds via a Injector lookup
2. if the method has a Delegate annotation, it responds with an instance of interface set in returnVal, adding the current JAXrs annotations to whatever are on that class.
• ex. if the method with Delegate has a Path annotation, and the returnval interface also has Path, these values are combined.
3. if RestAnnotationProcessor.delegationMap contains a mapping for this, and the returnVal is properly assigned as a ListenableFuture, it responds with an http implementation.
4. otherwise a RuntimeException is thrown with a message including: method is intended solely to set constants

Author:

Adrian Cole

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AsyncRestClientProxy.Factory

Field Summary

Fields

Modifier and Type	Field and Description
protected Logger	logger
protected long	requestTimeoutMilliseconds maximum duration of an unwrapped http Request

Constructor Summary

Constructors

Constructor and Description
AsyncRestClientProxy(com.google.inject.Injector injector, AsyncRestClientProxy.Factory factory, RestAnnotationProcessor<T> util, com.google.inject.TypeLiteral<T> typeLiteral, com.google.common.cache.LoadingCache<ClassMethodArgs,Object> delegateMap)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	hashCode()
Object	invoke(Object o, Method method, Object[] args)
boolean	isRestCall(Method method)
Object	lookupValueFromGuice(Method method)
Object	propagateContextToDelegate(Method method, Object[] args)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

requestTimeoutMilliseconds

@Inject(optional=true)
@Named(value="jclouds.request-timeout")
protected long requestTimeoutMilliseconds

maximum duration of an unwrapped http Request

logger

protected Logger logger

Constructor Detail

AsyncRestClientProxy

@Inject
public AsyncRestClientProxy(com.google.inject.Injector injector,
                           AsyncRestClientProxy.Factory factory,
                           RestAnnotationProcessor<T> util,
                           com.google.inject.TypeLiteral<T> typeLiteral,
                           @Named(value="async")
                           com.google.common.cache.LoadingCache<ClassMethodArgs,Object> delegateMap)

Method Detail

invoke

public Object invoke(Object o,
            Method method,
            Object[] args)
              throws Throwable

Specified by:

invoke in interface InvocationHandler

Throws:

Throwable

isRestCall

public boolean isRestCall(Method method)

propagateContextToDelegate

public Object propagateContextToDelegate(Method method,
                                Object[] args)
                                  throws ExecutionException

Throws:

ExecutionException

lookupValueFromGuice

public Object lookupValueFromGuice(Method method)

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object