如何过滤apache骆驼中的消息

Question

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

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

JMS队列=>过滤器（Bean的方法）=>（真）=>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"); 
    }
}