2016-06-10 184 views
0

我正在尝试在交易中创建一个拥有rabbitmq消费者的骆驼路线。我使用Spring引导和atomikos进行tx管理。 Rabbit MQ队列已经设置了x-dead-letter-exchange和路由密钥。骆驼RabbitMq交易消费者

我应该如何将我的rabbitmq连接工厂包装到JTA tx manager中?我尝试了交易块,但它不起作用。另外我没有在RabbitMq组件中看到一个设置tx manager的选项。

回答

0

将您的rabbitMq连接工厂从骆驼包装到Jms组件中。当使用WebSphereMQ时,我通常有一个包装模式:JmsComponent - > Spring CachingConnectionFactory - > MQQueueConnectionFactory。您可以在JmsComponent上配置您的交易信息。

+0

well camel-rabbitmq组件是单独构建的,不能包装在jms组件中。虽然camel-amqp支持,但不幸的是它支持amqp 1.0协议,即使在启用了amqp 1.0插件后,它也不能与rabbitmq一起工作。我在rabbitmq论坛上提出了这个问题。 – VGaur

+0

请勿直接使用camel-rabbitmq组件。您可以轻松使用camel-jms组件,然后插入rabbitMQ连接工厂 –