Apache Camel JMS/AMQP组件仅在需要时创建目标队列

Question

我目前正在开发一个使用Camel和Spring Boot的集成应用程序。集成应用程序中有一个骆驼路由，它从源Artemis代理接收消息，该消息被转换并发送到另一个Artemis代理。骆驼路线如下所示：

from（source Queue）。进程（转换处理器）。到（目标队列）

当骆驼路由开始时，它会重新创建from和to中提到的队列名称，并且之前的消息会丢失。我们不希望发生这种情况。

我发现的一种方法是在Artemis ActiveMQ代理中。xml，禁用队列和主题自动创建，并使用Artemis API创建队列。

我的问题是，我们可以配置camelJMS/AMQP组件仅在队列不存在并且如果存在则使用现有队列时创建队列吗？

Answer 1

我不知道Artemis，但代理删除带有消息的队列听起来很奇怪。至少它的“兄弟”ActiveMQ在默认情况下具有您期望的行为：如果队列不存在，则会自动创建队列，但如果它们已经存在，则只会保留。

您确定队列是在路由开始时重新创建的吗？这些队列是持久的吗？可能是消费者只是耗尽了队列吗？我还发现了一个名为auto-delete-quures的Artemis队列属性，如果队列被消费者耗尽，它会删除队列。

自动删除队列当自动创建的JMS队列同时具有0个消费者和0条消息时，代理是否应自动删除这些队列。

Answer 2

默认情况下，Camel将使用DynamicDestinationResolver。您可以创建自己的自定义DestinationResolver，并将其插入endpoint（或组件）

.to("jms:queue:myQueue?destinationResolver=MyCustomDestinationResolver");

您还可以使用JndiDestinationResolver，默认情况下，它不会回退到创建动态目标。