2011-05-17 96 views
2

在我的應用程序使用apache駝峯(mavenized,春季dsl)構建,我從 隊列讀取消息,根據數據中的某些條件需要丟棄大約3/5的消息有效載荷。如何篩選apache駱駝郵件

但我是新來的apache駱駝,不知道如何調用一個bean的方法,並基於 返回值(布爾值),如果真正轉發消息到下一個bean進行處理。

JMS隊列=>篩選(Bean的方法)=>(真)=>豆(處理數據)

回答

3

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