0

我有一个流如下，source(jms-ibmmq) -> Process -> Process -> sink(jdbc-oracle)

数据摄取工作正常。但是作为我的流的一部分，我的接收器（jdbc-oracle）可能会关闭（或）网络中存在一些问题，从而阻止了对 oracle 数据库的持久性。

我要问的是如何处理此故障以及 spring xd 可以提供哪些开箱即用的选项？是否有一种模式通常用于处理导致处理/接收器模块的流中的这些故障？

4

1 回答 1

1

请参阅有关此 JIRA 问题的评论，他们解释了我们添加的文档更改，以解释如何在消息总线中配置死信。

此外，我们提供了这样的机制，如果所有四个模块都部署到同一个容器（以及所有符合部署条件的容器），我们将直接连接这些模块，以便将接收器中的错误返回到源（在您的情况下导致 JMS 消息回滚）。

这是通过将模块count属性设置为0（意味着部署在所有符合条件的容器上 - 如果有的话 - 或所有容器，如果没有条件）。

此功能在 master 上可用（它是在 M7 之后添加的）。

于 2014-07-03T20:12:25.357 回答