mqgetc.java

实现Java接口的MQ编程

import com.ibm.mq.*;


public class MQGetC{
  
  public static void main(String args[])throws MQException{
   try{	
   	MQEnvironment.CCSID = 1381;         //要与队列管理器的一样                   
	MQEnvironment.hostname = "localhost";          // 队列管理器所在的机器名，要能ping通
    MQEnvironment.port = 1414;                          // 队列管理器的监听端口
    MQEnvironment.channel  = "CHTEST"; 
    	MQQueueManager qmgr=new MQQueueManager("TESTQM");   //队列管理器名称
    MQQueue queue = qmgr.accessQueue("QTEST",MQC.MQOO_INPUT_AS_Q_DEF);  //队列
    MQMessage  theMessage     = new MQMessage();
	MQGetMessageOptions gmo = new MQGetMessageOptions();
	queue.get(theMessage,gmo);
	//System.out.println("the message length is:"+theMessage.getDataLength());
	//int i=theMessage.getDataLength();
	System.out.println("the message is:"+theMessage.readLine());
	queue.close();
	qmgr.disconnect();
   }catch(Exception e) {
    		System.out.println(e);
   }
  }
  
}