我实现了一个自定义 <inbound-channel-adapter>
,扩展 MessageProducerSupport
,有点像 ImapIdleChannelAdapter
来自spring集成 . 此入站通道适配器的目标是在LDAP上启动 persistent 搜索,并且每次在LDAP中进行新的更改时,它都会将更改发送到通道,然后发送到 <int-http:outbound-channel-adapter>
. 但是,我希望在成功发送消息时能够将其记录到已处理的数据库中 . 你能不能用一些想法帮助我完成这项任务?非常感谢你!
1 回答
实现这一目标的最简单方法是将_933864_
<int-http:outbound-channel-adapter>
作为publish-subscribe
并再添加一个<int-jdbc:outbound-channel-adapter>
.仅当第一个订户完成其工作时才会调用该第二个订户 . 在这种情况下,相同的
Message
将被发送到数据库适配器 .另一个选项是基于
<request-handler-advice-chain>
和ExpressionEvaluatingRequestHandlerAdvice
,当你可以指定onSuccessExpression
和successChannel
一起发送一些东西到另一个通道,以获得良好的适配器处理结果 .