我是骆驼的新手,正在努力实现如下目标:
我需要处理 5 条并行消息,对于第 6 条消息,Throttler 应该拒绝该消息并抛出一些异常。在更高版本中,我可以看到 rejectExecution 可以处理这种情况。谁能告诉我如何用 camel 2.2.0 版本实现同样的效果
from("seda:a")
.throttle(100).rejectExecution(true)
.to("seda:b");
但这适用于更高版本,在 camel 2.2.0 中寻找类似的东西
如果该功能是在高版本中添加的,则您无法在旧版本中执行此操作。 Camel 2.x 也停产了。
您可以将自己的节流器编写为 Java 处理器/bean,然后使用它。