Package org.springframework.cloud.task.launcher

Class TaskLauncherSink

java.lang.Object

org.springframework.cloud.task.launcher.TaskLauncherSink

public class TaskLauncherSink
extends Object

A sink stream application that launches a tasks.

Author:

Glenn Renfro

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TaskLauncherSink()

Method Summary

Modifier and Type	Method	Description
Consumer<org.springframework.messaging.Message<TaskLaunchRequest>>	taskLauncherSink()	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 Details

taskLauncher

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

Constructor Details

TaskLauncherSink

public TaskLauncherSink()

Method Details

taskLauncherSink

@Bean
public Consumer<org.springframework.messaging.Message<TaskLaunchRequest>> taskLauncherSink()

Launches a task upon the receipt of a valid TaskLaunchRequest.

Returns:

the Consumer that will retrieve messages from binder.