org.springframework.cloud.dataflow.server.service.impl

Class DefaultTaskService

java.lang.Object

org.springframework.cloud.dataflow.server.service.impl.DefaultTaskService

All Implemented Interfaces:

TaskService

public class DefaultTaskService
extends Object
implements TaskService

Default implementation of the TaskService interface. Provide service methods for Tasks. Several properties in this class are annotated with Value annotations:

• spring.datasource.url
• spring.datasource.username
• spring.datasource.password
• spring.datasource.driverClassName

All four properties default to null if not set.

Author:

Michael Minella, Marius Bogoevici, Glenn Renfro, Mark Fisher, Janne Valkealahti, Gunnar Hillert

Constructor Summary

Constructors

Constructor and Description
DefaultTaskService(TaskDefinitionRepository repository, DeploymentIdRepository deploymentIdRepository, org.springframework.cloud.deployer.resource.registry.UriRegistry registry, ResourceLoader resourceLoader, org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher) Initializes the DefaultTaskService.

Method Summary

Methods

Modifier and Type	Method and Description
void	executeTask(String taskName, Map<String,String> runtimeProperties, List<String> runtimeParams) Execute a task with the provided task name and optional runtime properties.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTaskService

public DefaultTaskService(TaskDefinitionRepository repository,
                  DeploymentIdRepository deploymentIdRepository,
                  org.springframework.cloud.deployer.resource.registry.UriRegistry registry,
                  ResourceLoader resourceLoader,
                  org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher)

Initializes the DefaultTaskService.

Parameters:

repository - the TaskDefinitionRepository this service will use for task CRUD operations.

deploymentIdRepository - the repository this service will use for deployment IDs

registry - URI registry this service will use to look up app URIs.

resourceLoader - the ResourceLoader that will resolve URIs to Resources.

taskLauncher - the launcher this service will use to launch task apps.

Method Detail

executeTask

public void executeTask(String taskName,
               Map<String,String> runtimeProperties,
               List<String> runtimeParams)

Description copied from interface: TaskService

Execute a task with the provided task name and optional runtime properties.

Specified by:

executeTask in interface TaskService

Parameters:

taskName - Name of the task. Must not be null or empty.

runtimeProperties - Optional runtime properties. Must not be null.

runtimeParams - Optional runtime commandline arguments