駱駝RabbitMq交易消費者

Question

我正在嘗試在交易中創建一個擁有rabbitmq消費者的駱駝路線。我使用Spring引導和atomikos進行tx管理。 Rabbit MQ隊列已經設置了x-dead-letter-exchange和路由密鑰。

我應該如何將我的rabbitmq連接工廠包裝到JTA tx manager中？我嘗試了交易塊，但它不起作用。另外我沒有在RabbitMq組件中看到一個設置tx manager的選項。

Answer 1

將您的rabbitMq連接工廠從駱駝包裝到Jms組件中。當使用WebSphereMQ時，我通常有一個包裝模式：JmsComponent - > Spring CachingConnectionFactory - > MQQueueConnectionFactory。您可以在JmsComponent上配置您的交易信息。