io.spring

Class TaskProcessor

java.lang.Object

io.spring.TaskProcessor

@EnableBinding(value=org.springframework.cloud.stream.messaging.Processor.class)
 @EnableConfigurationProperties(value=TaskProcessorProperties.class)
public class TaskProcessor
extends Object

A processor that takes the maven repository coordinates and datasource configuration for a task and sends a TaskLaunchRequest message to a task sink.

Author:

Glenn Renfro

Constructor Summary

Constructors

Constructor and Description
TaskProcessor()

Method Summary

Modifier and Type	Method and Description
Object	setupRequest(String message)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskProcessor

public TaskProcessor()

Method Detail

setupRequest

@Transformer(inputChannel="input",
             outputChannel="output")
public Object setupRequest(String message)