Apache Camel/ActiveMQ优先级路由

Question

我有两个拥有相同消费者的AMQ队列。第一个队列（Q1）处理97%的消息，另一个队列（Q2）仅处理3%。问题是，Q2中的消息需要在消息排队后立即进行处理。所以我的问题是，当一条消息在第二季度可用时，我需要以某种方式暂停第一条路线，以吸引消费者。apache camel路由如下所示：

<route id="q1">
    <from uri="jms:recordAnalysisRequests" />
    <to uri="bean:analysisService" />
</route>
<route id="q2">
    <from uri="jms:recordAnalysisRequestsFastTrack" />
    <to uri="bean:analysisService" />
</route>

应该使用什么策略？我不认为我可以使用重新定序器，因为Q1可能有成千上万的消息排队，我不能把所有的消息都放在重新定序器批处理中。我在看路由节流，但我不知道如何做到这一点。我还想知道我是否可以通过动物园管理员节点进行同步。如果这个解决方案可行，我需要一些指导。

Answer 1

您可以将所有消息放在一个队列中，并使用消息优先级http://activemq.apache.org/how-can-i-support-priority-queues.html

第二种选择，使用驼峰重排序器

<route id="q1">
    <from uri="jms:recordAnalysisRequests" />
    <setHeader headerName="CustomPriority">
       <constant>2</constant>       
    </setHeader>
    <to uri="direct:analysisDirect" />
</route>
<route id="q2">
    <from uri="jms:recordAnalysisRequestsFastTrack" />
    <setHeader headerName="CustomPriority">
       <constant>1</constant>       
    </setHeader>
    <to uri="direct:analysisDirect" />
</route>
<route id="q3">
    <from uri="direct:analysisDirect">
    <resequence>
        <header>CustomPriority</header>
        <to uri="bean:analysisService" />
    </resequence>
</route>

第三个选项（Camel 2.12）不是使用重新排序器，而是使用带有PriorityBlockingQueue的SEDAendpointhttps://camel.apache.org/seda.html#SEDA-选择BlockingQueueImplementation