org.springframework.cloud.dataflow.server.config

Class DataflowAsyncAutoConfiguration

java.lang.Object

org.springframework.cloud.dataflow.server.config.DataflowAsyncAutoConfiguration

All Implemented Interfaces:

org.springframework.scheduling.annotation.AsyncConfigurer

@Configuration(proxyBeanMethods=false)
 @ConditionalOnBean(value=org.springframework.cloud.dataflow.server.config.EnableDataFlowServerConfiguration.Marker.class)
 @ConditionalOnProperty(prefix="spring.cloud.dataflow.async",
                       name="enabled",
                       havingValue="true")
 @AutoConfigureAfter(value=org.springframework.boot.autoconfigure.task.TaskExecutionAutoConfiguration.class)
 @EnableAsync
public class DataflowAsyncAutoConfiguration
extends Object
implements org.springframework.scheduling.annotation.AsyncConfigurer

Enables async executions for the Spring Cloud Dataflow server. Uses the Spring Boot autoconfigured TaskExecutorBuilder to create an async executor and register it with name DATAFLOW_ASYNC_EXECUTOR.

Author:

Tobias Soloschenko

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASYNC_PROPS_PREFIX
static String	DATAFLOW_ASYNC_EXECUTOR

Constructor Summary

Constructors

Constructor and Description
DataflowAsyncAutoConfiguration(org.springframework.boot.task.TaskExecutorBuilder taskExecutorBuilder)

Method Summary

Modifier and Type	Method and Description
Executor	getAsyncExecutor()
org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler	getAsyncUncaughtExceptionHandler()

Methods inherited from class java.lang.Object

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

Field Detail

ASYNC_PROPS_PREFIX

public static final String ASYNC_PROPS_PREFIX

See Also:

Constant Field Values

DATAFLOW_ASYNC_EXECUTOR

public static final String DATAFLOW_ASYNC_EXECUTOR

See Also:

Constant Field Values

Constructor Detail

DataflowAsyncAutoConfiguration

public DataflowAsyncAutoConfiguration(org.springframework.boot.task.TaskExecutorBuilder taskExecutorBuilder)

Method Detail

getAsyncExecutor

@Bean(name="dataflowAsyncExecutor")
public Executor getAsyncExecutor()

Specified by:

getAsyncExecutor in interface org.springframework.scheduling.annotation.AsyncConfigurer

getAsyncUncaughtExceptionHandler

public org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler()

Specified by:

getAsyncUncaughtExceptionHandler in interface org.springframework.scheduling.annotation.AsyncConfigurer