轮询器

Spring 集成还提供了一个流畅的 API,允许您为AbstractPollingEndpoint实现配置PollerMetadata。您可以使用Pollers构建器工厂来配置常见的 bean 定义或从IntegrationFlowBuilder EIP 方法创建的 bean 定义,如下例所示

@Bean(name = PollerMetadata.DEFAULT_POLLER)
public PollerSpec poller() {
    return Pollers.fixedRate(500)
        .errorChannel("myErrors");
}

有关更多信息,请参阅 Javadoc 中的PollersPollerSpec

如果您使用 DSL 构建PollerSpec作为@Bean,请不要在 bean 定义中调用getObject()方法。PollerSpec是一个FactoryBean,它根据规范生成PollerMetadata对象并初始化其所有属性。