【发布时间】:2018-07-01 12:46:05
【问题描述】:
我想向 MQ 服务器发送一条消息并接收返回的输出消息。比如消息是“pwd”,我收到回的消息应该是目录路径如“/usr/home”。但是,我的 receiveMessage 返回与我发送的“pwd”完全相同的消息。有没有办法让我的 receiveMessage 返回目录补丁?
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 );
谢谢
【问题讨论】:
-
MQ 不会为您运行 unix 命令。您需要一个应用程序来读取收到的消息,运行命令,然后将回复消息与响应一起发回。
-
哦!我懂了!谢谢,我不知道。
标签: java jms message-queue ibm-mq