36.7. jms-style Selectors
SQS 不允许选择器,但您可以使用 Camel Filter EIP 和设置适当的 visibilityTimeout 来有效地达到此目的。当 SQS 分配消息时,它将在尝试将消息分配给不同的消费者之前等待可见性超时,除非收到 DeleteMessage。默认情况下,Camel 始终在路由末尾发送 DeleteMessage,除非路由失败。要实现适当的过滤,且不会在成功完成路由时发送 DeleteMessage,请使用 Filter:
from("aws-sqs://MyQueue?amazonSQSClient=#client&defaultVisibilityTimeout=5000&deleteIfFiltered=false")
.filter("${header.login} == true")
.to("mock:result");
在上面的代码中,如果交换没有适当的标头,它不会通过过滤器 AND 将其从 SQS 队列中删除。5000 miliseconds 后,消息将对其他消费者可见。