| 发表于:2007-06-13 16:05:353楼 得分:70 |
将消息放入你的本地队列中,然后取出来 import java.io.ioexception; import com.ibm.mq.mqc; import com.ibm.mq.mqexception; import com.ibm.mq.mqgetmessageoptions; import com.ibm.mq.mqmessage; import com.ibm.mq.mqputmessageoptions; import com.ibm.mq.mqqueue; import com.ibm.mq.mqqueuemanager; public class mqsample{ //定义队列管理器和队列的名称 private static string qmname; private static string qname; public static void main(string args[]) { try{ //第一个参数是队列管理器名,第二个参数是队列名 //qmname = args[0].trim(); //qname = args[1].trim(); qmname = "qm_test "; qname = "lq_test "; }catch(exception e){ system.out.println( "usage: java mqsample 队列管理器名 队列名 "); system.exit(0); } try { //定义并初始化队列管理器对象并连接 mqqueuemanager qmgr = new mqqueuemanager(qmname); // 设置将要连接的队列属性 // note. all websphere mq options are prefixed with mqc in java. int openoptions = mqc.mqoo_input_as_q_def ¦ mqc.mqoo_output; //连接队列 mqqueue localq = qmgr.accessqueue(qname, openoptions); //定义一个简单的消息 mqmessage putmessage = new mqmessage(); putmessage.writeutf( "hello world! "); //设置写入消息的属性(默认属性) mqputmessageoptions pmo = new mqputmessageoptions(); //将消息写入队列 localq.put(putmessage,pmo); mqmessage retrievedmessage = new mqmessage(); retrievedmessage.messageid = putmessage.messageid; //设置取出消息的属性(默认属性) mqgetmessageoptions gmo = new mqgetmessageoptions(); // 从队列中取出消息 localq.get(retrievedmessage, gmo); string msgtext = retrievedmessage.readutf(); system.out.println( "the message is: " + msgtext); //关闭队列 localq.close(); //从队列管理器断开 qmgr.disconnect(); }catch (mqexception ex) { system.out.println( "a websphere mq error occurred : completion code " + ex.completioncode + " reason code " + ex.reasoncode); }catch (ioexception ex) { system.out.println( "an error occurred whilst writing to the message buffer: " + ex); }catch(exception ex){ ex.printstacktrace(); } } } | | |
|