Programmatically start and stop certain IntegrationFlows in Spring Integration?

Question

I've created some IntegrationFlow's in spring integration like this:

IntegrationFlows.from(..).id("test").autoStartup(false). ..

How can I lookup this integration flow in Spring Integration and start it? I'm looking for something similar to org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry that can be used to start and stop RabbitListener instances.

Answer 1

Use the bean name of the flow

@Bean
public IntegrationFlow flow() {...}


...


@Autowired
public IntegrationFlow flow;

...

flow.stop();

(or getBean("flow") on the ApplicationContext).