如何 运行 向 MQ 服务器发送消息并取回输出消息

Question

我想向 MQ 服务器发送消息并接收返回的输出消息。比如消息是"pwd"，我收到回来的消息应该是“/usr/home”这样的目录路径。但是，我收到的消息 return 与我发送 "pwd" 的消息完全相同。有没有办法让我的 receiveMessage 可以 return 目录补丁？

connectionFactory.setCCDTURL(ccdt.tab);
connectionFactory_.setQueueManager(QUEUE_MANAGER_NAME);
MQQueueConnection connection = (MQQueueConnection)connectionFactory.createQueueConnection();
connection.start();
MQQueue mqQueue= new MQQueue();
MQQueueSender sender =  (MQQueueSender) session.createSender(mqQueue);
JMSTextMessage message = (JMSTextMessage)session.createTextMessage("pwd");
message.setJMSCorrelationID(correlationId);
sender.send(message);
MQQueueSession session =(MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
String selector = "JMSCorrelationID = '" + correlationId + "'";
MQQueueReceiver receiver = (MQQueueReceiver) session.createReceiver(mqQueue, selector);
TextMessage receiveMessage = (TextMessage) receiver.receive(500);
receiver.close();
System.out.println("Received Message: " + receiveMessage );

谢谢

Answer 1

您提供的示例只是将文本为 pwd 的消息放入队列，然后从队列中取回相同的消息。您看到的结果是预期的结果。

如果您希望能够将消息发送到一个队列，在该队列中将执行该消息的内容并将该命令的输出返回给您，您需要编写一个程序来执行该功能。