Camel和JMS以正确的顺序从高级队列中消费消息

Question

我将Apache Camel与Oracle高级队列和JMS结合使用时遇到了问题。

它是关于一个分发消息的应用程序。消息在Camel的帮助下被接收并在Oracle高级队列中排队。然后它们被Camel使用并转发到目标系统。对于消息传递失败的情况，在高级队列中定义了重试计数，以便重复消息传递。

如果Camel现在将消息退出队列并将其发送到不可用的目标系统，则会引发HttpOperationFailedException或NoSuchEndpointException。这些被捕获并执行回滚。

此时，预期消息传递将按照“重试计数”中定义的频率重试，然后移动到异常队列。然而，正在发生的是队列中的下一条消息被发送。

由于消息的内容部分相互依赖，因此必须按顺序处理它们。

我认为 JMS 库的使用存在错误配置，但我不确定并且没有发现任何可以影响此行为的内容。

使用的 JMS 库是 Oracle AqApi v 11.2.0.3。

以下是骆驼路线的代码：

from("jms-camel-component:myComponent.AQ?jmsMessageType=Text").routeId("deliveryToTarget")
        .transacted()                
        .setExchangePattern(ExchangePattern.InOut)                        
        .setHeader(Exchange.HTTP_QUERY, constant("throwExceptionOnFailure=false"))
        .setHeader(Exchange.CONTENT_TYPE, constant("application/xml; charset=UTF-8"))
        .doTry()
            .recipientList(header("endpointTarget"))
            .endDoTry()
            .process(ResponseProzessor.getInstance())
            .log("Message was delivererd.")
        .doCatch(HttpOperationFailedException.class, NoSuchEndpointException.class)    
            .process(ResponseProzessor.getInstance())
            .log("Error occured.")
            .rollback()
        .end();

下面是 JmsComponent 配置：

JmsComponent jmsComponent = new JmsComponent(scc);
jmsComponent.setConnectionFactory(connectionFactory);
jmsComponent.setTransactionManager(tm);
jmsComponent.setMaxConcurrentConsumers(1);            
jmsComponent.setMaxMessagesPerTask(1);                  
jmsComponent.setIncludeSentJMSMessageID(true);

提前感谢您的帮助！

更新

我想，我已经找到了所描述行为的原因。在高级队列上配置了延迟。只要延迟持续，队列中的下一条消息就会取消排队。消息不是随机取消排队的，而是根据优先级取消排队的。

我真的认为这是必须在消费者身上配置的东西。是否有任何技巧可以将 camel-jms-组件配置为使用队列中的第一条消息，只要它没有提交或移动到异常队列？我没有找到直接在骆驼上配置它的选项......

Answer 1

我不是Oracle AQ专家，但据我所知，这是队列上的设置，而不是客户端上的设置。

sort_list 参数确定消息取消排队的顺序。创建队列表后，无法更改邮件排序顺序

来自:http://docs . Oracle . com/CD/b 19306 _ 01/server . 102/b 14257/AQ _ admin . htm

你很可能有ENQ_TIME或COMMIT_TIME——这可能已经满足了你的需求。

当然，你的消费者必须是唯一的。