Mule JMS 请求-响应

Question

我有一个使用 JMS 入站端点的 Mule 流 - 端点是请求响应 - 当我运行发送 ObjectMessage 的测试时，请求会到达后续转换器，我可以在处理周期结束时看到响应.

但是，当我从外部 Java 客户端向队列提交 JMS 请求时出现问题 - JMS 消息被提交，但响应负载始终为空 - 我在我的场景下面包含了一个代码 sn-p

p>

谢谢

使用以下 Active MQ 测试类解决了该问题。

 connectionFactory = new ActiveMQConnectionFactory(connectionUri);
 connection = connectionFactory.createConnection();
 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
 replyQueue = session.createQueue("REPLY.Q");
 requestQueue = session.createQueue("REQUEST.Q");
 messageConsumer = session.createConsumer(replyQueue);
 messageConsumer.setMessageListener(this);
 connection.start();

 ObjectMessage message = session.createObjectMessage();
 message.setObject(getCompositeEntity());
 message.setJMSReplyTo(replyQueue);
 String randomStr = UUID.randomUUID().toString();
 message.setJMSCorrelationID(randomStr);
 MessageProducer publisher = session.createProducer(requestQueue);
 publisher.send(message);

Answer 1

您从外部客户端发布的 JMS 消息是否将其 JMSReplyTo 属性正确设置为队列（永久或临时）？