【发布时间】:2015-12-20 23:47:28
【问题描述】:
我正在从 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。
任何想法,我在这里缺少什么?
谢谢。
【问题讨论】:
标签: java queue jms ibm-mq websphere-liberty