org.springframework.cloud.dataflow.server.config.features

Class TaskConfiguration

java.lang.Object

org.springframework.cloud.dataflow.server.config.features.TaskConfiguration

@Configuration
 @EnableConfigurationProperties(value={TaskConfigurationProperties.class,CommonApplicationProperties.class,DockerValidatorProperties.class,LocalPlatformProperties.class})
 @EnableMapRepositories(basePackages="org.springframework.cloud.dataflow.server.job")
 @EnableTransactionManagement
public class TaskConfiguration
extends Object

Author:

Thomas Risberg, Janne Valkealahti, Glenn Renfro, Michael Minella, Ilayaperumal Gopinathan, Gunnar Hillert, Christian Tzolov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskConfiguration.H2ServerConfiguration
static class	TaskConfiguration.NoH2ServerConfiguration

Constructor Summary

Constructors

Constructor and Description
TaskConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.batch.core.explore.support.JobExplorerFactoryBean	jobExplorerFactoryBean(DataSource dataSource)
LauncherInitializationService	launcherInitializationService(LauncherRepository launcherRepository, List<TaskPlatform> platforms)
TaskPlatform	localTaskPlatform(LocalPlatformProperties localPlatformProperties)
SimpleJobServiceFactoryBean	simpleJobServiceFactoryBean(DataSource dataSource, org.springframework.batch.core.repository.support.JobRepositoryFactoryBean repositoryFactoryBean, org.springframework.batch.core.explore.JobExplorer jobExplorer, org.springframework.transaction.PlatformTransactionManager dataSourceTransactionManager)
TaskJobService	taskJobExecutionRepository(JobService service, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, TaskDefinitionRepository taskDefinitionRepository, TaskService taskService)
TaskService	taskService(TaskDefinitionRepository repository, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, org.springframework.cloud.task.repository.TaskRepository taskExecutionRepository, AppRegistryService registry, LauncherRepository launcherRepository, ApplicationConfigurationMetadataResolver metadataResolver, TaskConfigurationProperties taskConfigurationProperties, AuditRecordService auditRecordService, CommonApplicationProperties commonApplicationProperties, TaskValidationService taskValidationService)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskConfiguration

public TaskConfiguration()

Method Detail

launcherInitializationService

@Bean
public LauncherInitializationService launcherInitializationService(LauncherRepository launcherRepository,
                                                                         List<TaskPlatform> platforms)

localTaskPlatform

@Bean
 @ConditionalOnProperty(value="spring.cloud.dataflow.task.enableLocalPlatform",
                       matchIfMissing=true)
public TaskPlatform localTaskPlatform(LocalPlatformProperties localPlatformProperties)

taskService

@Bean
public TaskService taskService(TaskDefinitionRepository repository,
                                     org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
                                     org.springframework.cloud.task.repository.TaskRepository taskExecutionRepository,
                                     AppRegistryService registry,
                                     LauncherRepository launcherRepository,
                                     ApplicationConfigurationMetadataResolver metadataResolver,
                                     TaskConfigurationProperties taskConfigurationProperties,
                                     AuditRecordService auditRecordService,
                                     CommonApplicationProperties commonApplicationProperties,
                                     TaskValidationService taskValidationService)

taskJobExecutionRepository

@Bean
public TaskJobService taskJobExecutionRepository(JobService service,
                                                       org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
                                                       TaskDefinitionRepository taskDefinitionRepository,
                                                       TaskService taskService)

simpleJobServiceFactoryBean

@Bean
public SimpleJobServiceFactoryBean simpleJobServiceFactoryBean(DataSource dataSource,
                                                                     org.springframework.batch.core.repository.support.JobRepositoryFactoryBean repositoryFactoryBean,
                                                                     org.springframework.batch.core.explore.JobExplorer jobExplorer,
                                                                     org.springframework.transaction.PlatformTransactionManager dataSourceTransactionManager)
                                                              throws Exception

Throws:

Exception

jobExplorerFactoryBean

@Bean
public org.springframework.batch.core.explore.support.JobExplorerFactoryBean jobExplorerFactoryBean(DataSource dataSource)