Spring Integration DSL参考文档代码示例无法编译
Spring Integration DSL参考文档代码示例无法编译
提问于 2021-07-16 05:05:06
官方Spring Integration DSL参考文档在https://docs.spring.io/spring-integration/reference/html/dsl.html#java-dsl的第一部分中提供了以下代码示例
@Configuration
@EnableIntegration
public class MyConfiguration {
@Bean
public AtomicInteger integerSource() {
return new AtomicInteger();
}
@Bean
public IntegrationFlow myFlow() {
return IntegrationFlows.from(integerSource::getAndIncrement,
c -> c.poller(Pollers.fixedRate(100)))
.channel("inputChannel")
.filter((Integer p) -> p > 0)
.transform(Object::toString)
.channel(MessageChannels.queue())
.get();
}
}当我将此代码复制粘贴到我的集成开发环境(IntelliJ)中时，在该行得到以下错误
return IntegrationFlows.from(integerSource::getAndIncrement,错误消息：
Cannot resolve symbol 'integerSource'我尝试过将getAndIncrement定义为messageSource的各种替代方法，但到目前为止，所有这些方法都产生了某种错误。
有没有办法让这个例子编译并运行？
回答 1
Stack Overflow用户
回答已采纳
发布于 2021-07-16 10:50:10
我们最近也发现了同样的问题。请查看最新快照中修复的文档：https://docs.spring.io/spring-integration/docs/5.5.2-SNAPSHOT/reference/html/dsl.html#java-dsl。固定代码如下所示：
@Bean
public IntegrationFlow myFlow() {
return IntegrationFlows.fromSupplier(integerSource()::getAndIncrement,
c -> c.poller(Pollers.fixedRate(100)))
.channel("inputChannel")
.filter((Integer p) -> p > 0)
.transform(Object::toString)
.channel(MessageChannels.queue())
.get();
}该版本将于下周发布。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/68400752
复制相关文章
相似问题
腾讯云开发者
