在Spring Intgegration DSL中连接JDBC存储支持的两个队列通道

Question

我正在尝试连接两个队列通道（由JDBC存储支持）。

@Configuration
public class DemoIntegration {
    @Bean
    public IntegrationFlow flow(MessageChannel firstJDBCChannel,
                                MessageChannel secondJDBCChannel) {
        return IntegrationFlows.from(firstJDBCChannel)
                .bridge(bridgeHandler -> bridgeHandler.poller(p -> p.fixedDelay(100L)))
                .handle(secondJDBCChannel)
                .get();
    }
}

Answer 1

您必须使用.handle(secondJDBCChannel).channel(secondJDBCChannel)而不是.handle(secondJDBCChannel)。没有什么要处理的--它是介于两者之间的通道。

有关更多信息，请参阅参考手册。