java - 以编程方式启动和停止 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();

(或 ApplicationContext 上的 getBean("flow"))。