Package org.springframework.cloud.dataflow.server.config

Class DataflowAsyncAutoConfiguration

java.lang.Object

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

All Implemented Interfaces:

AsyncConfigurer

@AutoConfiguration
@ConditionalOnBean(org.springframework.cloud.dataflow.server.config.EnableDataFlowServerConfiguration.Marker.class)
@ConditionalOnProperty(prefix="spring.cloud.dataflow.async",
                       name="enabled",
                       havingValue="true")
@AutoConfigureAfter(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	Description
static final String	ASYNC_PROPS_PREFIX
static final String	DATAFLOW_ASYNC_EXECUTOR

Constructor Summary

Constructors

Constructor	Description
DataflowAsyncAutoConfiguration(org.springframework.boot.task.ThreadPoolTaskExecutorBuilder taskExecutorBuilder)

Method Summary

Modifier and Type	Method	Description
Executor	getAsyncExecutor()
AsyncUncaughtExceptionHandler	getAsyncUncaughtExceptionHandler()

Methods inherited from class java.lang.Object

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

Field Details

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 Details

DataflowAsyncAutoConfiguration

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

Method Details

getAsyncExecutor

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

Specified by:

getAsyncExecutor in interface AsyncConfigurer

getAsyncUncaughtExceptionHandler

public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler()

Specified by:

getAsyncUncaughtExceptionHandler in interface AsyncConfigurer