org.springframework.cloud.task.launcher

Class TaskLauncherSink

java.lang.Object

org.springframework.cloud.task.launcher.TaskLauncherSink

@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class)
public class TaskLauncherSink
extends Object

A sink stream application that launches a tasks.

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
org.springframework.cloud.deployer.spi.task.TaskLauncher	taskLauncher

Constructor Summary

Constructors

Constructor and Description
TaskLauncherSink()

Method Summary

Modifier and Type	Method and Description
void	taskLauncherSink(TaskLaunchRequest taskLaunchRequest) Launches a task upon the receipt of a valid TaskLaunchRequest.

Methods inherited from class java.lang.Object

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

Field Detail

taskLauncher

@Autowired
public org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher

Constructor Detail

TaskLauncherSink

public TaskLauncherSink()

Method Detail

taskLauncherSink

@ServiceActivator(inputChannel="input")
public void taskLauncherSink(TaskLaunchRequest taskLaunchRequest)
                                                              throws Exception

Launches a task upon the receipt of a valid TaskLaunchRequest.

Parameters:

taskLaunchRequest - is a TaskLaunchRequest containing the information required to launch a task.

Throws:

Exception - if error occurs during task launch.