11.6. selective Consumer

图 11.5 “selective Consumer Pattern” 中显示的特定 消费者 模式描述了将过滤器应用到传入信息的消费者，以便仅处理满足特定选择条件的消息。

图 11.5. selective Consumer Pattern

您可以使用以下方法之一在 Apache Camel 中实施选择性消费者模式：

JMS 选择器是涉及 JMS 标头和 JMS 属性的 predicate 表达式。如果选择器评估为 true，则允许 JMS 消息到达消费者，如果选择器评估为 false，则 JMS 消息被阻止。例如，要使用来自队列的消息（选择 ），并仅选择其国家代码属性等于 US 的消息，您可以使用以下 Java DSL 路由：

from("jms:selective?selector=" + java.net.URLEncoder.encode("CountryCode='US'","UTF-8")).
    to("cxf:bean:replica01");

其中选择器字符串 CountryCode='US' 必须采用 URL 编码（使用 UTF-8 字符），以避免解析查询选项时出现问题。本例假定 JMS 属性 CountryCode 是由发送者设置的。有关 JMS 选择器的详情，请参考 “JMS 选择器”一节。

您还可以在 ActiveMQ 端点上定义 JMS 选择器。例如：

from("acivemq:selective?selector=" + java.net.URLEncoder.encode("CountryCode='US'","UTF-8")).
    to("cxf:bean:replica01");

如需了解更多详细信息，请参阅 ActiveMQ：JMS Selectors 和 ActiveMQ 消息属性。

如果无法在消费者端点上设置选择器，您可以在路由中插入过滤器处理器。例如，您可以定义一个选择消费者，该消费者仅使用 Java DSL 来处理具有美国国家代码的消息，如下所示：

from("seda:a").filter(header("CountryCode").isEqualTo("US")).process(myProcessor);

可以使用 XML 配置定义相同的路由，如下所示：

<camelContext id="buildCustomProcessorWithFilter" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="seda:a"/>
    <filter>
      <xpath>$CountryCode = 'US'</xpath>
      <process ref="#myProcessor"/>
    </filter>
  </route>
</camelContext>

有关 Apache Camel 过滤器处理器的详情，请参考 第 8.2 节 “Message Filter”。