MessageStore 支持 QueueChannel，带有 Spring Integration+ Java Config

弹簧集成参考指南指的是使用 MessageStore 实现来为 QueueChannel 提供持久性。

它被提到了很多次，但所有示例都使用 XML 配置，即

<int:channel id="dbBackedChannel">
    <int:queue message-store="channelStore"/>
</int:channel>

<bean id="channelStore" class="o.s.i.jdbc.store.JdbcChannelMessageStore">
    <property name="dataSource" ref="dataSource"/>
    <property name="channelMessageStoreQueryProvider" ref="queryProvider"/>
</bean>

但实施队列通道没有设置 MessageStore 的方法

那么如何在不使用 XML 配置的情况下创建带有 MessageStore 的 QueueChannel 呢？

对 XML 配置的功能进行逆向工程，这就是答案。

您将 MessageStore 包装在消息组队列

所以它看起来像这样

@Bean
public MessageChannel messageStoreBackedChannel() {
    return new QueueChannel(
        new MessageGroupQueue(<<MessageStoreImplementation>>, "Group ID")
    );
}