@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class) public class TaskLauncherSink extends Object
Modifier and Type | Field and Description |
---|---|
org.springframework.cloud.deployer.spi.task.TaskLauncher |
taskLauncher |
Constructor and Description |
---|
TaskLauncherSink() |
Modifier and Type | Method and Description |
---|---|
void |
taskLauncherSink(TaskLaunchRequest taskLaunchRequest)
Launches a task upon the receipt of a valid TaskLaunchRequest.
|
@Autowired public org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher
@ServiceActivator(inputChannel="input") public void taskLauncherSink(TaskLaunchRequest taskLaunchRequest) throws Exception
taskLaunchRequest
- is a TaskLaunchRequest containing the information required
to launch a task.Exception
- if error occurs during task launch.Copyright © 2021 Pivotal Software, Inc.. All rights reserved.