Comment filtrer les messages dans Apache Camel

Question

Dans mon application construite en utilisant Apache Camel (mavenisé, spring dsl), je lis des messages d'une file d'attente. Environ 3/5 des messages doivent être rejetés en fonction de certaines conditions dans les données de la charge utile.

Mais je suis nouveau dans Apache Camel et je ne sais pas comment appeler la méthode d'un bean et, en fonction de la valeur de retour (boolean), si elle est vraie, transférer le message au bean suivant pour le traitement.

File d'attente JMS => Filtre (méthode du bean) => (vrai) => Bean (traiter les données)

Answer 1

Voir le modèle de filtre de message

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