Spring集成outbound-channel-adapter和数据库持久化

Question

我正在开发一个使用出站通道适配器将消息发布到队列的应用程序。有一个新的要求，就是消息处理过程中产生的唯一id，在成功发布到队列后，应该持久化到数据库中，而不需要等待任何回复。

有人可以建议什么是最好的方法。

这是我现有应用程序中的内容。

<int:gateway id="writerGateway" service-interface="CustomService" default-request-channel="writerChannel">
</int:gateway>

<int-jms:outbound-channel-adapter channel="writerChannel" jms-template="jmsTemplate" destination-name="${queueName}" extract-payload="true"/>

<int:channel id="writerChannel">
    <int:interceptors>
        <int:wire-tap channel="writerLogger"/>
    </int:interceptors>
</int:channel>

<int:logging-channel-adapter id="writerLogger" logger-name="writerLogger" level="INFO" expression="'Sending ' + payload?.size() + ' events'"/>

任何帮助将不胜感激。

谢谢， AK

Answer 1

将writerChannel 设为<publish-subscribe-channel/> 并为其订阅第二个流（order="2"），例如transformer -> jdbc-outbound-channel-adapter。在jms适配器上设置order="1"，如果jms发送成功将调用第二个流。

或者，使用<recipient-list-router/>。