如何在apachecamel中过滤消息

Question

在我使用 apache Camel (mavenized, spring dsl) 构建的应用程序中，我正在读取来自 一个队列中，根据负载中数据的某些情况，大约有3/5的消息需要被丢弃。

但我是 apache Camel 的新手，不知道如何调用 bean 的方法并基于 返回值 (boolean) ，如果 true 将消息转发到下一个 bean 进行处理。

JMS队列=> Filter（Bean的方法）==> (true) =>Bean(处理数据)

Answer 1

请参阅消息过滤模式

from("jms:queue:start")
    .filter().method(MyBean.class, "isGoldCustomer").to("bean:process");

public static class MyBean {
    public boolean isGoldCustomer(@Header("level") String level) { 
        return level.equals("gold"); 
    }
}