11.8. jms-style Selectors

SQS 不允许选择器，但您可以使用 Camel Filter EIP 和设置适当的 visibilityTimeout 来有效地达到此目的。当 SQS 分配消息时，它将在尝试将消息分配给不同的消费者之前等待可见性超时，除非收到 DeleteMessage。默认情况下，Camel 始终在路由末尾发送 DeleteMessage，除非路由失败。要实现适当的过滤，且不会在成功完成路由时发送 DeleteMessage，请使用 Filter：

from("aws2-sqs://MyQueue?amazonSQSClient=#client&defaultVisibilityTimeout=5000&deleteIfFiltered=false&deleteAfterRead=false")
.filter("${header.login} == true")
  .setProperty(Sqs2Constants.SQS_DELETE_FILTERED, constant(true))
  .to("mock:filter");

在上面的代码中，如果交换没有适当的标头，它不会通过过滤器 AND 将其从 SQS 队列中删除。5000 毫秒后，消息将对其他用户可见。

请注意，我们必须将属性 Sqs2Constants.SQS_DELETE_FILTERED 设置为 true，以指示 Camel 发送 DeleteMessage （如果被过滤）。