java - 如何使用Camel在运行时更改处理器属性？

我有一个用Java DSL编写的Camel路由定义，如下所示：

from(myEndpoint)
.throttle(200)
.to(myOtherEndpoint);

这使用Throttler连接了我的两个端点，该端点将消息流限制为每秒200条消息。

我正在寻找一种在运行时更改maximumRequestCount /秒的方法。
所以我需要以某种方式到达被称为Throttler的实例并更改属性。

如何进入节流阀？

最佳答案

好吧，我自己弄清楚了...

您需要自己定义Throttler实例。

Throttler throttler = new Throttler(null, 200);

然后，您可以在这样的路由中使用它，因为Throttler实现了Processor接口：

from(myEndpoint)
.process(throttler)
.to(myOtherEndpoint);

您可以随时更改节流阀的属性。