@EnableBinding(value=PollingSink.class) @EnableConfigurationProperties(value={TriggerProperties.class,DataflowTaskLauncherSinkProperties.class,org.springframework.cloud.dataflow.rest.client.config.DataFlowClientProperties.class}) public class TaskLauncherDataflowSinkConfiguration extends Object
Constructor and Description |
---|
TaskLauncherDataflowSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
void |
addInterceptorToPollableMessageSource(org.springframework.boot.context.event.ApplicationPreparedEvent event) |
LaunchRequestConsumer |
launchRequestConsumer(org.springframework.cloud.stream.binder.PollableMessageSource input,
org.springframework.cloud.dataflow.rest.client.DataFlowOperations dataFlowOperations,
org.springframework.integration.util.DynamicPeriodicTrigger trigger,
TriggerProperties triggerProperties,
DataflowTaskLauncherSinkProperties sinkProperties) |
org.springframework.integration.util.DynamicPeriodicTrigger |
periodicTrigger(TriggerProperties triggerProperties) |
public TaskLauncherDataflowSinkConfiguration()
@Bean public org.springframework.integration.util.DynamicPeriodicTrigger periodicTrigger(TriggerProperties triggerProperties)
@EventListener public void addInterceptorToPollableMessageSource(org.springframework.boot.context.event.ApplicationPreparedEvent event)
@Bean public LaunchRequestConsumer launchRequestConsumer(org.springframework.cloud.stream.binder.PollableMessageSource input, org.springframework.cloud.dataflow.rest.client.DataFlowOperations dataFlowOperations, org.springframework.integration.util.DynamicPeriodicTrigger trigger, TriggerProperties triggerProperties, DataflowTaskLauncherSinkProperties sinkProperties)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.