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

Question

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

我想持续检查数据库表中的更改，我认为这可以通过 Spring Integration JDBC 实现。

我的数据库位于不同的 Docker 容器中，我的应用程序(Spring Boot)位于不同的 Docker 容器中。我不能在这里使用 Hibernate Interceptor，因为其他一些应用程序将编辑表。

Answer 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");
}

本章名为查找 Java 和 DSL 配置的类名。因此，应该作为 XML 配置的良好迁移指南。