如何使用JMS将msg发送到Websphere MQ以及对MQ MGR的特定答复

问题描述

我需要构建一个Java独立应用程序，该应用程序具有将消息发送到MQSeries的功能，该消息指定了答复队列和答复MQMgr.我能够使用SimpleP2P示例中的代码发送消息，但是无法指定回复队列和回复MQMgr

I need to build a java standalone application with ability to send messages to MQSeries specifying reply-to queue and reply-to MQMgr.I was able to use the code in SimpleP2P example to send a message, but unable to specify the reply-to queue and reply-to 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");
    }
}

推荐答案

尝试一下:-

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

这篇关于如何使用JMS将msg发送到Websphere MQ以及对MQ MGR的特定答复的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！