在Apache Camel中，如果一个endpoint不存在，我如何接收一个错误？

Question

我们使用Camel fluent构建器来设置一系列复杂的路由，其中我们使用RecipientList功能使用动态路由。

我们遇到过这样的问题：在某些情况下，收件人列表包含不存在的消息传递endpoint（例如，seda： not有之类的东西）。

一个简单的例子是这样的：

from("seda:SomeSource")....to("seda:notThere");

我如何配置路由，以便如果交换机尝试路由到一个不存在的endpoint，就会抛出错误？

我正在使用Camel 2.9. x，并且我已经尝试了死信通道和各种错误处理程序实现，（似乎）没有记录错误或警告。

我看到的唯一日志表明Camel正在(试图)向不存在的endpoint发送:

2013-07-03 16:07:08,030|main|DEBUG|o.a.c.p.SendProcessor|>>>> Endpoint[seda://notThere] Exchange[Message: x.y.Z@293b9fae]

提前感谢！

Answer 1

在这种情况下，所有终结点的行为都不同。

如果您尝试写入不存在的ftp服务器，您肯定会收到错误（连接被拒绝或以其他方式）。

许多endpoint也是如此。

如果 不存在，则会创建 SEDA 队列，并且消息将保留在那里。因此，您的路由实际上发送到“notThere”，并且消息仍将存在，直到应用程序重新启动或有人开始使用来自seda：notThere的消息。这就是 seda 队列的设计方式。如果将 seda 队列的大小设置为 to（“seda：notThere？size=100”），那么如果没有人读取（或读取缓慢），您将在消息 101 和转发时收到异常。

如果你需要确定某个路由正在消耗你的消息，使用“direct”而不是“seda”。你甚至可以有一些中间层来使用seda关于staging的特性和直接知道有一个活跃的消费者的特性(如果从接收者列表发送，可能有用户输入(上帝禁止)。

from("whatever").recipentList( ... ); // "direct:ep1" work, "direct:ep2" throws exception

from("direct:ep1").to("seda:ep1");
from("seda:ep1").doRealStagedStuffHere();