org.springframework.integration.gateway

Class GatewayCompletableFutureProxyFactoryBean

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.gateway.GatewayProxyFactoryBean

org.springframework.integration.gateway.GatewayCompletableFutureProxyFactoryBean

All Implemented Interfaces:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, FactoryBean<Object>, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, NamedComponent, TrackableComponent

public class GatewayCompletableFutureProxyFactoryBean
extends GatewayProxyFactoryBean

A gateway proxy factory that can handle JDK8 CompletableFutures. If a gateway method returns CompletableFuture exactly, one will be returned and the results of the CompletableFuture.supplyAsync(Supplier, java.util.concurrent.Executor) method call will be returned.

If you wish your integration flow to return a CompletableFuture to the gateway in a reply message, the async executor must be set to null.

If the return type is a subclass of CompletableFuture, it must be returned by the integration flow and the async executor (if present) is not used.

Since:

4.2

Author:

Gary Russell

Field Summary

Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

lifecycleCondition, lifecycleLock

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
GatewayCompletableFutureProxyFactoryBean()
GatewayCompletableFutureProxyFactoryBean(Class<?> serviceInterface)

Method Summary

Modifier and Type	Method and Description
Object	invoke(org.aopalliance.intercept.MethodInvocation invocation)

Methods inherited from class org.springframework.integration.gateway.GatewayProxyFactoryBean

doInvoke, doStart, doStop, getAsyncExecutor, getObject, getObjectType, isSingleton, onInit, setAsyncExecutor, setBeanClassLoader, setDefaultReplyChannel, setDefaultReplyTimeout, setDefaultRequestChannel, setDefaultRequestTimeout, setErrorChannel, setGlobalMethodMetadata, setMapper, setMethodMetadataMap, setReactorEnvironment, setServiceInterface, setShouldTrack, setTypeConverter

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName, getComponentType

Constructor Detail

GatewayCompletableFutureProxyFactoryBean

public GatewayCompletableFutureProxyFactoryBean()

GatewayCompletableFutureProxyFactoryBean

public GatewayCompletableFutureProxyFactoryBean(Class<?> serviceInterface)

Method Detail

invoke

public Object invoke(org.aopalliance.intercept.MethodInvocation invocation)
              throws Throwable

Specified by:

invoke in interface org.aopalliance.intercept.MethodInterceptor

Overrides:

invoke in class GatewayProxyFactoryBean

Throws:

Throwable