如需使用最新稳定版本,请使用 Spring Integration 7.0.4spring-doc.cadn.net.cn

轮询器

Spring Integration 还提供了一种流畅的 API,允许您为 PollerMetadata 实现配置 AbstractPollingEndpoint。 您可以使用 Pollers 构建器工厂来配置通用的 bean 定义或从 IntegrationFlowBuilder EIP 方法创建的 bean 定义,如下示例所示:spring-doc.cadn.net.cn

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

请参阅 Javadoc 中的 PollersPollerSpec 以获取更多信息。spring-doc.cadn.net.cn

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