Spring Integration JDBC 入站轮询器基于 Java 的配置

【问题标题】：Spring Integration JDBC inbound poller Java Based ConfigurationSpring Integration JDBC 入站轮询器基于 Java 的配置
【发布时间】：2019-02-19 00:07:06
【问题描述】：

我想使用 Spring Integration JDBC 配置入站池。到目前为止，我已经找到了 xml 配置，但我想在 java 配置中实现。

我想不断检查 db 表中的变化，我认为这可以通过 Spring Integration JDBC 实现。

我的 Db 在不同的 Docker 容器中，而我的应用程序（Spring Boot）在不同的 Docker 容器中。我不能在这里使用 Hibernate 拦截器，因为其他一些应用程序会编辑表。

【问题讨论】：

对于那些面临这个问题的人，我已经实现了示例spring应用程序link

标签： java spring spring-boot spring-integration

【解决方案1】：

不确定您调查了哪些资源，但我们在官方Reference Manual 此示例的首页上有：

@Bean
@InboundChannelAdapter(value = "fooChannel", poller = @Poller(fixedDelay="5000"))
public MessageSource<?> storedProc(DataSource dataSource) {
    return new JdbcPollingChannelAdapter(dataSource, "SELECT * FROM foo where status = 0");
}

章节名为Finding Class Names for Java and DSL Configuration。所以，应该作为一个很好的从 XML 配置迁移的指南。

【讨论】：

嘿！我已经找到了我的问题的解决方案。你的回答是对的。我已将 xml 配置转换为 java 配置。