java - 如何使用 JMS 将消息发送到 Websphere MQ，并对 MQ MGR 进行特定回复

Question

我需要构建一个 java 独立应用程序，能够将消息发送到 MQSeries，指定回复队列和回复 MQMgr。 我能够使用 SimpleP2P 示例中的代码发送消息，但无法指定回复队列和回复 MQMgr

public static void main(String[] args) {
    try {
        MQQueueConnectionFactory cf = new MQQueueConnectionFactory();


        cf.setHostName("xyz.com");
        cf.setPort(141600);
        cf.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
        cf.setQueueManager("QMG");
        cf.setChannel("CHANNEL");


        MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
        MQQueue queue = (MQQueue) session.createQueue("queue:///A.QUEUE");
        MQQueueSender sender = (MQQueueSender) session.createSender(queue);

        long uniqueNumber = System.currentTimeMillis() % 1000;
        String fileText = convertXMLFileToString("test.xml");
        System.out.println("fileText " + fileText);

        JMSTextMessage message = (JMSTextMessage) session.createTextMessage(fileText);


        connection.start();

        System.out.println("before Sent message:\\n" + message);

        sender.send(message);
        System.out.println("Sent message:\\n" + message);

        sender.close();

        session.close();
        connection.close();

        System.out.println("\\nSUCCESS\\n");
    } catch (JMSException jmsex) {
        System.out.println(jmsex);
        System.out.println("\\nFAILURE\\n");
    } catch (Exception ex) {
        System.out.println(ex);
        System.out.println("\\nFAILURE\\n");
    }
}

Answer 1

试试这个:-

MQQueue replyToQ = new MQQueue(QMgrName, ReplyQueue);
Destination replyTo = (Destination) replyToQ;
message.setJMSReplyTo(replyTo);