ibm mq 教程_ibm mq_资讯导航：手机资讯_易配网(6)

//Setuptheoptionsonthequeuewewishtoopen

师/记帐员/mqc/ipqc/钳加工师傅/钳加技工/折弯技。openoptions = mqc.mqoo_output。int openoptions = mqc.mqoo_input_as_q_def | mqc.mqoo_output。

//Nowspecifythequeuethatwewishtoopenandtheopenoptions

System.out.println("Accessingqueue:"+qName);

MQQueuequeue=qMgr.accessQueue(qName,openOptions);

//DefineasimpleWebSphereMQMessage...

MQMessagemsg=newMQMessage();

//...andwritesometextinUTF8format

msg.writeUTF("Hello,World!");

//Specifythedefaultputmessageoptions

MQPutMessageOptionspmo=newMQPutMessageOptions();

//Putthemessagetothequeue

System.out.println("Sendingamessage...");

/*

*在此测试一下mq的传输次列

*

*/

for(intj=0;j<5;j++){

Stringstr="test11111111111";

str=str+j;

msg.writeUTF(str);

queue.put(msg,pmo);

}

queue.put(msg,pmo);

//Nowgetthemessagebackagain.FirstdefineaWebSphereMQmessage

//toreceivethedata

MQMessagercvMessage=newMQMessage();

//Specifydefaultgetmessageoptions

MQGetMessageOptionsgmo=newMQGetMessageOptions();

//Getthemessageoffthequeue.

System.out.println("...andgettingthemessagebackagain");

queue.get(rcvMessage,gmo);

//Anddisplaythemessagetext...

StringmsgText=rcvMessage.readUTF();

System.out.println("Themessageis:"+msgText);

//Closethequeue

System.out.println("Closingthequeue");

queue.close();

//DisconnectfromtheQueueManager

System.out.println("DisconnectingfromtheQueueManager");

qMgr.disconnect();

System.out.println("Done!");

}

catch(MQExceptionex){

System.out.println("AWebSphereMQErroroccured:CompletionCode"

本文来自电脑杂谈，转载请注明本文网址：
https://www.pc-fly.com/a/jisuanjixue/article-95152-6.html