ActiveMQ -从JMS远程主机接收时无法识别对象

Question

我在两个JBoss服务器上设置了一个JMS请求回复。在客户机中，我使用camel-jms和Fuse route创建调用。

.setExchangePattern(ExchangePattern.InOut)
.to(camelContext.getEndpoint(JMS_BEANID, JmsQueueEndpoint.class))

基本上，它将创建临时队列并发送到服务器。在服务器中，我创建了MessageListener的实现来监听消息。

在调试视图中，message.getJMSReplyTo()返回ActiveMQTemporaryQueue的一个实例。但是，当我尝试检查message.getJMSReplyTo() instanceof ActiveMQTemporaryQueue时，它返回false。我尝试自己创建ActiveMQTemporaryQueue，检查结果按预期返回true，例如：

public void onMessage(Message message) {
    Destination replyTo = message.getJMSReplyTo();
    if (replyTo instanceof ActiveMQTemporaryQueue) {
        // false, although the debugger show it is ActiveMQTemporaryQueue object
    }
    Destination test = new ActiveMQTemporaryQueue("localhost", "testQueue", (ActiveMQSession)session);
    if (test instanceof ActiveMQTemporaryQueue) {
        // true
    }
}

客户端和服务器在两个不同的Maven项目中(两个不同的war，部署在不同的服务器上，相同的工作区)。

我不知道发生了什么。你有什么意见建议？

Answer 1

我的猜测是这是某种类型的类加载问题，但根据您提供的信息很难判断。

也就是说，我强烈建议您不要在代码中使用任何实现对象(即ActiveMQTemporaryQueue)。如果你想做的只是一个请求/回复，那么绝对不需要使用任何实现对象。如果您需要知道getJMSReplyTo()返回的值是否是临时队列，那么您可以简单地使用replyTo instanceof javax.jms.TemporaryQueue。如果你这么做了，我想你的问题就解决了。