filter - 如何在 apache camel 中过滤消息

Question

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

但我是 apache camel 的新手，不知道如何调用 bean 的方法和基于返回值( bool 值)，如果为真，则将消息转发给下一个 bean 进行处理。

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

Answer 1

参见 message filter pattern

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"); 
    }
}