org.springframework.cloud.task.app.composedtaskrunner

Class TaskLauncherTasklet

java.lang.Object

org.springframework.cloud.task.app.composedtaskrunner.TaskLauncherTasklet

All Implemented Interfaces:

org.springframework.batch.core.step.tasklet.Tasklet

public class TaskLauncherTasklet
extends Object
implements org.springframework.batch.core.step.tasklet.Tasklet

Executes task launch request using Spring Cloud Data Flow's Restful API then returns the execution id once the task launched. Note: This class is not thread-safe and as such should not be used as a singleton.

Author:

Glenn Renfro

Constructor Summary

Constructors

Constructor and Description
TaskLauncherTasklet(org.springframework.cloud.dataflow.rest.client.TaskOperations taskOperations, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, ComposedTaskProperties composedTaskProperties, String taskName)

Method Summary

Modifier and Type	Method and Description
org.springframework.batch.repeat.RepeatStatus	execute(org.springframework.batch.core.StepContribution contribution, org.springframework.batch.core.scope.context.ChunkContext chunkContext) Executes the task as specified by the taskName with the associated properties and arguments.
void	setArguments(List<String> arguments)
void	setProperties(Map<String,String> properties)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskLauncherTasklet

public TaskLauncherTasklet(org.springframework.cloud.dataflow.rest.client.TaskOperations taskOperations,
                           org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
                           ComposedTaskProperties composedTaskProperties,
                           String taskName)

Method Detail

setProperties

public void setProperties(Map<String,String> properties)

setArguments

public void setArguments(List<String> arguments)

execute

public org.springframework.batch.repeat.RepeatStatus execute(org.springframework.batch.core.StepContribution contribution,
                                                             org.springframework.batch.core.scope.context.ChunkContext chunkContext)

Executes the task as specified by the taskName with the associated properties and arguments.

Specified by:

execute in interface org.springframework.batch.core.step.tasklet.Tasklet

Parameters:

contribution - mutable state to be passed back to update the current step execution

chunkContext - contains the task-execution-id used by the listener.

Returns:

Repeat status of FINISHED.