轮询器

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

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

请参阅Javadoc中的Pollers和PollerSpec以了解更多信息。

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