Package io.spring

Class TaskProcessor

java.lang.Object

io.spring.TaskProcessor

@EnableConfigurationProperties(TaskProcessorProperties.class)
@Configuration
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	Description
TaskProcessor()

Method Summary

Modifier and Type	Method	Description
Function<org.springframework.messaging.Message<String>,org.springframework.messaging.Message<TaskLaunchRequest>>	processRequest()

Methods inherited from class java.lang.Object

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

Constructor Details

TaskProcessor

public TaskProcessor()

Method Details

processRequest

@Bean
public Function<org.springframework.messaging.Message<String>,org.springframework.messaging.Message<TaskLaunchRequest>> processRequest()