public static void main(String args[]) { try { properties.put("hostname", "10.1.1.1"); properties.put("port", new Integer(1414)); properties.put("channel", "DC.SVRCONN"); properties.put("CCSID", new Integer(1381)); properties.put("transport","MQSeries");
// Create a connection to the queue manager qMgr = new MQQueueManager(qmName,properties); // Set up the options on the queue we wish to open... int openOptions = 16; // Now specify the queue that we wish to open, // and the open options... MQQueue remoteQ = qMgr.accessQueue(qName, openOptions);
// Define a simple WebSphere MQ message, and write some text in UTF format.. MQMessage putMessage = new MQMessage(); putMessage.writeUTF("Test"); // specify the message options... MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept the defaults, same as MQPMO_DEFAULT // put the message on the queue remoteQ.put(putMessage,pmo); System.out.println("Message has been input into the Remote Queue");
// Close the queue... remoteQ.close(); // Disconnect from the queue manager qMgr.disconnect(); }catch (MQException ex) { // If an error has occurred in the above, try to identify what went wrong // Was it a WebSphere MQ error? System.out.println("A WebSphere MQ error occurred : Completion code " + ex.completionCode + " Reason code " + ex.reasonCode); }catch (IOException ex) { // Was it a Java buffer space error? System.out.println("An error occurred whilst writing to the message buffer: " + ex); }catch(Exception ex){ ex.printStackTrace(); } } } ------------------------------------------------------------------------------------------- 運行程序后，請在B機器的本地隊列LQ_88888888中檢查是否有消息存在，假如有說明測試成功。 讀者可以自行編寫把消息從對方的本地隊列讀取出來的程序。 假如讀者對以上的內容有任何疑問，可以和我聯系，qianh@cntmi.com 版權所有，嚴禁轉載
參考資料： 1、《WebSphere MQ System Administration Guide》Third edition (May 2004)，SC34-6068-02 2、《WebSphere MQ Using Java》Third edition (January 2004)，SC34-6066-02 附件：MQTest.java(2K)
