骆驼节流

Question

我试图弄清楚骆驼的节流概念。我已经看到了骆驼的航线政策，但这适用于许多飞行中的交换。

我的路线如下：

routeBuilders.add(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("rabbitmq://127.0.0.1:5672/abc?queue=a&username=XXX&password=XXX&autoAck=false&durable=true&exchangeType=direct&autoDelete=false")
                .to("rabbitmq://127.0.0.1:5672/abc?queue=b&username=XXX&password=XXX&autoAck=false&durable=true&exchangeType=direct&autoDelete=false");
            }
        });

现在我的用例是，我想在这些路由之间传输比如说2000条消息，我知道可以通过.throttle(2000)来完成。但是，我不得不决定如何在下一个2000条消息被路由时控制它。我只想在接收者队列变为空时路由下2000条消息。

例如，消息从队列A路由到B。假设2K消息已成功路由，现在我想挂起我的路由，这样它就不会传输更多的消息，直到队列b变为空（假设有一个使用者正在从队列b中提取消息）

在这方面的任何帮助/指导都是非常感谢的。

Answer 1

您可以为此使用路由策略。您可以在路由策略中实现挂起/恢复路由的逻辑,以限制路由。

我们有一个开箱即用的策略，它使用Camel中的飞行消息数作为衡量标准。但是您应该添加逻辑来检查队列是否为空。

路由策略的文档在这里

null

• https://github.com/apache/camel/blob/master/camel-core/src/main/java/org/apache/camel/impl/throttlinginflightroutepolicy.java