ActiveMQTemporaryQueue

ActiveMQTemporaryQueue

我正在两个JBoss服务器上设置JMS请求答复。
在客户端中,我使用camel-jms和Fuse路由创建呼叫。

.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项目中(两个不同的战争,部署在不同的服务器上,相同的工作空间)。

我不知道发生了什么你有什么建议吗?

最佳答案

我的猜测是这是某种类型的类加载问题,但是很难用您提供的信息来分辨。

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

07-26 07:32