public class GatewayCompletableFutureProxyFactoryBean extends GatewayProxyFactoryBean
CompletableFuture
s. 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.
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
Constructor and Description |
---|
GatewayCompletableFutureProxyFactoryBean() |
GatewayCompletableFutureProxyFactoryBean(Class<?> serviceInterface) |
Modifier and Type | Method and Description |
---|---|
Object |
invoke(org.aopalliance.intercept.MethodInvocation invocation) |
doInvoke, doStart, doStop, getAsyncExecutor, getGateways, getObject, getObjectType, isSingleton, onInit, setAsyncExecutor, setBeanClassLoader, setDefaultReplyChannel, setDefaultReplyChannelName, setDefaultReplyTimeout, setDefaultRequestChannel, setDefaultRequestChannelName, setDefaultRequestTimeout, setErrorChannel, setErrorChannelName, setGlobalMethodMetadata, setMapper, setMethodMetadataMap, setReactorEnvironment, setServiceInterface, setShouldTrack, setTypeConverter
doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName, getComponentType
public GatewayCompletableFutureProxyFactoryBean()
public GatewayCompletableFutureProxyFactoryBean(Class<?> serviceInterface)
public Object invoke(org.aopalliance.intercept.MethodInvocation invocation) throws Throwable
invoke
in interface org.aopalliance.intercept.MethodInterceptor
invoke
in class GatewayProxyFactoryBean
Throwable