【发布时间】:2015-10-10 16:09:47
【问题描述】:
我正在尝试使用 java 配置 Jms 和 WebSphere,并在远程系统中使用 Jboss 6.3。但是在创建 MQQueueConnection 类时遇到 ClassNotFoundException。我请在这里编写代码。 实际上 M 没有得到正确的步骤,我从 IBM Knowledge Center 获得了帮助,但这对我没有帮助。 请任何知道它的人指导我和下面的代码需要哪些 jar 文件?
try {
MQQueueConnectionFactory cf = new MQQueueConnectionFactory();
// Config
cf.setHostName("167.190.249.202");
cf.setPort(1422);
cf.setTransportType(WMQConstants.WMQ_CM_CLIENT);
cf.setQueueManager("QM.EMPIRE");
cf.setChannel("EMPIRE.CONN");
MQQueueConnection connection = (MQQueueConnection) cf.createQueueConnection();
MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
MQQueue queue = (MQQueue) session.createQueue("queue:///Q1");
MQQueueSender sender = (MQQueueSender) session.createSender(queue);
MQQueueReceiver receiver = (MQQueueReceiver) session.createReceiver(queue);
long uniqueNumber = System.currentTimeMillis() % 1000;
JMSTextMessage message = (JMSTextMessage) session.createTextMessage("SimplePTP "+ uniqueNumber);
// Start the connection
connection.start();
sender.send(message);
System.out.println("Sent message:\\n" + message);
JMSMessage receivedMessage = (JMSMessage) receiver.receive(10000);
System.out.println("\\nReceived message:\\n" + receivedMessage);
sender.close();
receiver.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");
}
}
}
【问题讨论】:
-
ClassNotFound表明配置有问题或安装不正确。帖子中没有提及使用哪个版本的 MQ 类、它们是如何安装的、CLASSPATH设置为什么、哪个 API 调用失败、LinkedException中的返回码是什么等。您是否有可能用一些诊断信息更新您的问题?
标签: ibm-mq