ActiveMQ：如何在使用临时队列时处理代理故障转移

Question

在我的JMS应用程序上，我们在生产者上使用临时队列，以便能够接收来自消费者应用程序的回复。

我在这个线程上遇到了与我完全相同的问题：http : //activemq.2283324.n4.nabble.com/jira-
Created-AMQ-3336-Temporary-Destination-errors-on-HA-failover-in -broker-
network-with-Failover-tt-
td3551034.html＃a3612738

每当我重新启动网络中的任意代理时，在尝试将答复发送到临时队列时，我的“使用者”应用程序日志中都会出现许多类似这样的错误：

javax.jms.InvalidDestinationException:
  Cannot publish to a deleted Destination: temp-queue://ID:...

然后我看到Gary的回应建议使用

jms.watchTopicAdvisories=false

作为客户端上的url参数brokerURL。我立即使用此附加参数更改了我的客户代理URL。但是，现在当我在网络中重新启动我的代理进行故障转移测试时，我看到了这样的错误：

javax.jms.JMSException: 
  The destination temp-queue:
    //ID:client.host-65070-1308610734958-2:1:1 does not exist.

我正在使用ActiveMQ 5.5版本。我的客户经纪人网址如下所示：

failover:(tcp://amq-host1:61616,tcp://amq-host2.tred.aol.com:61616,tcp://amq-host3:61616,tcp://amq-host4:61616)?jms.useAsyncSend=true&timeout=5000&jms.watchTopicAdvisories=false

另外，这是我的4个代理之一的activemq配置XML：
amq1.xml

这里有人可以调查这个问题并建议我在此设置中犯了什么错误。

为了进一步阐明我在代码中如何执行请求响应：

1. 我已经使用了每个生产者的目的地（即临时队列），并将其设置在每条消息的回复标头中。
2. 我已经在JMSCorrelationID标头中发送每条消息的唯一相关标识符。
3. 据我所知，甚至Camel和Spring也使用临时队列进行请求-响应机制。唯一的区别是Spring JMS实现为每个消息创建并销毁了临时队列，而我在生产者的生命周期中创建了临时队列。当客户端（生产者）应用程序关闭时，或者当AMQ代理意识到此临时队列没有附加活动的生产者时，该临时队列将被销毁。
4. 我已经在生产者端为每条消息设置了一条消息到期时间，以使消息不会在队列中停留太长时间（60秒）。

Answer 1

有一个代理属性org.apache.activemq.broker.BrokerService＃cacheTempDestinations应该有助于故障转移：案例。在xml配置中将其设置为true，并且在客户端断开连接时不会立即删除临时目标。快速故障转移：重新连接将能够再次从临时队列中产生和/或使用。

有一个基于timeBeforePurgeTempDestinations的计时器任务（默认为5秒），用于处理高速缓存的删除。

请注意，在activemq-core中没有使用该属性的测试，因此我无法对此提供任何保证。