mqputc.java

实现Java接口的MQ编程

import com.ibm.mq.*;


public class MQPutC{
   public static void main(String args[])throws MQException{
   try{	
   	MQEnvironment.CCSID = 1381;   //要与队列管理器的一样
	MQEnvironment.hostname = "localhost";    // 队列管理器所在的机器名，要能ping通
        MQEnvironment.port = 1414;                   // 队列管理器的监听端口
        MQEnvironment.channel  = "CHANNEL1"; 
	MQQueueManager qmgr=new MQQueueManager("WMBQM6");    //队列管理器名称
        MQQueue queue = qmgr.accessQueue("IN",MQC.MQOO_OUTPUT ); //队列
        MQMessage theMessage    = new MQMessage();
	MQPutMessageOptions pmo = new MQPutMessageOptions();
	theMessage.format = MQC.MQFMT_STRING;
        theMessage.characterSet = 1208;
	theMessage.writeString("<Message><JJBH>1</JJBH><BJMC>2</BJMC><AJLX>3</AJLX><BJSJ>4</BJSJ><BJFS>张旭</BJFS><JJR>7</JJR></Message>");
        //theMessage.priority=9;
        //theMessage.Persistence = MQPER_PERSISTENT;
        queue.put(theMessage,pmo);
        //System.out.println("the message length is:"+theMessage.getDataLength());
        //int i=theMessage.getDataLength();
	System.out.println("the message send ok!");
	queue.close();
	qmgr.disconnect();
   }catch(Exception e) {
    		System.out.println(e);
   }
  }
  
}