Camel RabbitMq 交易消费者

Question

我正在尝试创建一个在事务中包含 rabbitmq 消费者的骆驼路线。我正在使用 Spring boot 和 atomikos 进行 tx 管理。 Rabbit MQ 队列已经设置了 x-dead-letter-exchange 和路由键。

我应该如何将我的 rabbitmq 连接工厂包装在 JTA tx manager 中？我尝试了交易块，但没有奏效。我也没有在 RabbitMq 组件中看到设置 tx 管理器的选项。

Answer 1

将rabbitMq 连接工厂包装在camel 的Jms 组件中。使用 WebSphereMQ 时，我通常有以下包装模式：JmsComponent -> Spring CachingConnectionFactory -> MQQueueConnectionFactory。您可以在 JmsComponent 上配置您的事务信息。