轮询器
Spring 集成还提供了一个流畅的 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 对象并初始化其所有属性。
|