轮询器
Spring Integration 还提供了一个 fluent API,可以让您为 AbstractPollingEndpoint
实现配置 PollerMetadata
。您可以使用 Pollers
构建工厂来配置常见的 bean 定义或从 IntegrationFlowBuilder
EIP 方法创建的定义,如下例所示:
@Bean(name = PollerMetadata.DEFAULT_POLLER)
public PollerSpec poller() {
return Pollers.fixedRate(500)
.errorChannel("myErrors");
}
请参阅 Pollers 和 PollerSpec 的 Javadoc 以获取更多信息。
important
如果你使用 DSL 来构建 PollerSpec
作为 @Bean
,不要在 bean 定义中调用 getObject()
方法。PollerSpec
是一个 FactoryBean
,它根据规范生成 PollerMetadata
对象并初始化其所有属性。