Spring Integration DSL 参考文档代码示例无法编译

Question

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();
    }
}

当我将此代码复制粘贴到我的 IDE (IntelliJ) 中时，我在这一行收到以下错误

        return IntegrationFlows.from(integerSource::getAndIncrement,

错误信息：

Cannot resolve symbol 'integerSource'

我尝试了各种将 getAndIncrement 定义为 messageSource 的替代方法，但到目前为止，它们都产生了某种错误。

有没有办法让这个例子编译和运行？

Answer 1

我们最近发现了同样的问题。请参阅最新快照中的固定文档：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();
}

下周发布。

Answer 2

您可以通过将from() 替换为fromSupplier() 来更改您的代码