来自同一产地的骆驼的多种途径

Question

我有一个包含多个消费者的JMS队列。我试着沿着骆驼的路线走，

<camel:camelContext id="camel-server">
        <camel:package>com.camlin.consumer</camel:package>

        <camel:route id="one">
            <camel:from uri="jms:queue:request" />
            <camel:choice>
                <camel:when>
                    <camel:simple>${header.type} == '1'</camel:simple>
                    <camel:to uri="bean:consumerBean?method=receive1" />
                </camel:when>
            </camel:choice>
        </camel:route>

        <camel:route id="two">
            <camel:from uri="jms:queue:request" />
            <camel:choice>
                <camel:when>
                    <camel:simple>${header.type} == '2'</camel:simple>
                    <camel:to uri="bean:consumerBean?method=receive2" />
                </camel:when>
            </camel:choice>
        </camel:route>

    </camel:camelContext>

信息是以，

producer.sendBodyAndHeader("Hello from Producer-1", "type", "1");
producer.sendBodyAndHeader("Hello from Producer-2", "type", "2");

只使用第一条消息。根据路由，第二条消息永远不会到达consumerBean。Q1.这里缺少配置吗？

我希望有多个路由，因为我需要动态地添加/删除路由。因此，在这里有一条具有多种选择的单一路线是不合适的。

Q2.骆驼通过头检查消息是否从队列中删除？因此它不能用于其他路由？更新:参考http://fusesource.com/docs/router/2.5/eip/MsgEnd-Selective.html。过滤器通过使用消息来工作。所以选择器是唯一的选择。

Answer 1

如果您希望您的所有路由(消费者)接收所有消息，那么您需要订阅一个主题。队列上的消息只能使用一次。有关主题的消息将传递给所有订阅的使用者。

如果要使用队列，可以使用JMS选择器。但是，选择器是一个端点选项，您尚未在代码片段中设置该选项。