Filter
The Message Filter from the EIP patterns allows you to filter messages
The following example shows how to create a Message Filter route consuming messages from an endpoint called queue:a, which if the Predicate is true will be dispatched to queue:b
Samples
Here is a little example in Java DSL:
from("direct:a")
.filter(simple("${header.foo} == 'bar'"))
.to("direct:b");
You can use many different languages as the predicate, such as XPath:
from("direct:start").
filter().xpath("/person[@name='James']").
to("mock:result");
Here is another example of using a bean to define the filter behavior
from("direct:start")
.filter().method(MyBean.class, "isGoldCustomer")
.to("mock:gold")
.end()
.to("mock:all");
public static class MyBean {
public boolean isGoldCustomer(@Header("level") String level) {
return level.equals("gold");
}
}
And the example in XML:
<bean id="myBean" class="com.foo.MyBean"/>
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="direct:a"/>
<filter>
<method ref="myBean" method="isGoldCustomer"/>
<to uri="direct:b"/>
</filter>
</route>
</camelContext>
Using stop
Stop is a bit different than a message filter as it will filter out all messages and end the route entirely (filter only applies to its child processor). Stop is convenient to use in a Content Based Router when you for example need to stop further processing in one of the predicates.
In the example below we do not want to route messages any further that
has the word Bye
in the message body. Notice how we prevent this in
the when predicate by using the .stop()
.
Knowing if Exchange was filtered or not
The Message Filter EIP will add a property on the Exchange that states if it was filtered or not.
The property has the key Exchange.FILTER_MATCHED
, which has the String
value of CamelFilterMatched
. Its value is a boolean indicating true
or false
. If the value is true
then the Exchange
was routed in the filter block. This property will be visible within the
Message Filter block who’s
Predicate matches (value set to true
), and to the
steps immediately following the Message Filter
with the value set based on the results of the last
Message Filter Predicate
evaluated.