7.7. JMS-style Selector

SQS 不允许选择器，但您可以使用 Camel Filter EIP 和设置适当的 可见Timeout 来有效地达到此目的。当 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");

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

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