org.springframework.cloud.dataflow.server.config

Class DataflowAsyncAutoConfiguration

java.lang.Object

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

All Implemented Interfaces:

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 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()
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 AsyncConfigurer

getAsyncUncaughtExceptionHandler

public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler()

Specified by:

getAsyncUncaughtExceptionHandler in interface AsyncConfigurer