以编程方式启动和停止 Spring Integration 中的某些 IntegrationFlows？

Question

我在 spring 集成中创建了一些 IntegrationFlow，如下所示：

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

如何在 Spring Integration 中查找此集成流程并启动它？我正在寻找类似于org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry可用于启动和停止RabbitListener实例的东西。

Answer 1

使用流的 bean 名称

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


...


@Autowired
public IntegrationFlow flow;

...

flow.stop();

（或getBean("flow")在ApplicationContext）。