【发布时间】:2016-06-02 21:44:05
【问题描述】:
我正在开发一个模块,它消耗一些 HTTP 资源,写入 postgres,最后将消息推送到消息总线 (RabbitMQ)。
我想弄清楚如何处理模块内的事务:如何封装我的 postgres 操作和推送到 RabbitMQ(即,如果消息无法推送到 RabbitMQ,我的 DB 操作应该回滚)?
谢谢。
【问题讨论】:
标签: spring-integration spring-xd
我正在开发一个模块,它消耗一些 HTTP 资源,写入 postgres,最后将消息推送到消息总线 (RabbitMQ)。
我想弄清楚如何处理模块内的事务:如何封装我的 postgres 操作和推送到 RabbitMQ(即,如果消息无法推送到 RabbitMQ,我的 DB 操作应该回滚)?
谢谢。
【问题讨论】:
标签: spring-integration spring-xd
有几种技术可以在事务中包装 Spring Integration 流的一部分;有关示例,请参见 this answer。
当然,您必须始终使用直接渠道。
【讨论】: