交易 Spring XD

Transaction Spring XD

我正在开发一个消耗一些 HTTP 资源的模块,在 postgres 中编写,最后将消息推送到消息总线 (RabbitMQ)。

我想弄清楚如何处理模块内的事务:如何封装我的 postgres 操作和推送到 RabbitMQ(即如果消息无法推送到 RabbitMQ,我的数据库操作应该回滚) ?

谢谢。

有多种技术可以将 Spring 集成流程的各个部分包装在事务中;有关示例,请参阅

当然,您必须始终使用直接渠道。