如何使用骆驼-activemq-starter 的事务处理标志回滚消息

Question

我正在使用带有yaml自动配置的cameactivemq启动器。当我对消费者使用“？transactiond=true”标志时，消息将转到DLQ。我所寻找的行为是，如果骆驼路由中出现异常，则不从队列中删除消息。这在camel-sjms和camel-jms中使用“transaction=true”标志，效果如预期。提前感谢您的帮助！下面是yaml配置。

camel:
  component:
    reactive-streams:
      thread-pool-max-size: 5
    activemq:
      broker-url: "tcp://localhost:61616"
      connection-factory: ActiveMQConnectionFactory
      transaction-manager: JmsTransactionManager

以下是路线在一般情况下的样子:

    fromF("activemq:queue:queue?transacted=true")
                    .routeId("stopThisRoute")
                    .process(exchange -> {
----- something ------
                    })
                    -------
                            throw new IllegalStateException();
========
                        })
                    .end();

Answer 1

添加ack模式解决了骆驼激活Q-starter的这个问题。可能不是“问题”，只是不同的行为。

camel:
  component:
    activemq:
      broker-url: "tcp://localhost:61616"
      connection-factory: CachingConnectionFactory
      transacted: true
      transaction-manager: JmsTransactionManager
      acknowledgement-mode-name: CLIENT_ACKNOWLEDGE