@EnableBinding(value=PollingSink.class) @EnableConfigurationProperties(value=TriggerProperties.class) @Import(value=org.springframework.cloud.dataflow.tasklauncher.TaskLauncherFunctionConfiguration.class) public class TaskLauncherSinkConfiguration extends Object
Constructor and Description |
---|
TaskLauncherSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.beans.factory.config.BeanPostProcessor |
addInterceptorToPollableMessageSource() |
LaunchRequestConsumer |
launchRequestConsumer(org.springframework.cloud.stream.binder.PollableMessageSource input,
TaskLauncherFunction taskLauncherFunction,
org.springframework.integration.util.DynamicPeriodicTrigger trigger,
TriggerProperties triggerProperties) |
org.springframework.integration.util.DynamicPeriodicTrigger |
periodicTrigger(TriggerProperties triggerProperties) |
@Bean public org.springframework.integration.util.DynamicPeriodicTrigger periodicTrigger(TriggerProperties triggerProperties)
@Bean public org.springframework.beans.factory.config.BeanPostProcessor addInterceptorToPollableMessageSource()
@Bean public LaunchRequestConsumer launchRequestConsumer(org.springframework.cloud.stream.binder.PollableMessageSource input, TaskLauncherFunction taskLauncherFunction, org.springframework.integration.util.DynamicPeriodicTrigger trigger, TriggerProperties triggerProperties)
Copyright © 2021 Pivotal Software, Inc.. All rights reserved.