java - IBM Websphere MQ 将 javax.jms.TextMessage 显示为

Question

我正在从 Java 代码向 Websphere MQ Server 发送消息，当我在 MQ 服务器上读取相同的消息时，它显示为:

message<RFH >

下面是将消息发送到MQ服务器的代码:

private void sendMessage() throws Exception {
        ConnectionFactory cf1 = (ConnectionFactory) new InitialContext().lookup("java:comp/env/jms/wmqCF");

        // Lookup Queue resource from JNDI
        Queue queue = (Queue) new InitialContext().lookup("java:comp/env/jms/wmqQ1");
        Connection con = cf1.createConnection();

        // start the connection to receive message
        con.start();

        // create a queue session to send a message
        Session sessionSender = con.createSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);

        MessageProducer send = sessionSender.createProducer(queue);

        TextMessage msg = sessionSender.createTextMessage("Liberty Sample Message");

        // send a sample message
        send.send(msg);

        if (con != null)
            con.close();
        System.out.println("Send Message Completed");
    }

预计显示为:Liberty Sample Message。

知道我在这里缺少什么吗？

谢谢。

Answer 1

如果您使用另一个 JMS 程序检索消息，则消息数据将为“Liberty Sample Message”。

您正在混合 JMS 和非 JMS 程序类型。

.lookup("java:comp/env/jms/wmqQ1");

将“TARGCLIENT”属性设置为 MQ。即 TARGCLIENT(MQ)

那么消息数据将不会有 RFH2 header 。