package com.bulain.wasmq;   
  
import org.apache.log4j.Logger;   
  
import java.io.InputStream;   
import java.util.Properties;   
  
import com.ibm.mq.MQC;   
import com.ibm.mq.MQEnvironment;   
import com.ibm.mq.MQException;   
import com.ibm.mq.MQGetMessageOptions;   
import com.ibm.mq.MQMessage;   
import com.ibm.mq.MQQueue;   
import com.ibm.mq.MQQueueManager;   
  
//----------------------------------------------   
// ……   
public class Main {   
     /**  
      * Logger for this class  
      */  
     private static final Logger logger = Logger.getLogger(Main.class);   
       
     private String strExtraSendXmlFileName = "jndi.properties";   
     private static Properties props;   
     static {   
         props = new Properties();   
         props.put("mqHostName","10.240.13.81");   
         props.put("mqPort","1414");   
         props.put("mqCCSID","932");        
         props.put("mqUserName","mqadmin");   
         props.put("mqPassword","Art515940");   
         props.put("mqQManager","QM_mphch085");   
         props.put("mqChannel","S_mphch085");   
         props.put("mqLocalOutQueue","clq_default_mphch085");   
         props.put("mqLocalInQueue","clq_default_mphch085");        
     }   
       
  
     public static void main(String[] args) {   
         Main test = new Main();   
         test.send();   
         test.recieve();   
     }   
  
     public void send() {   
         // MQ?送   
         try {   
             // 建立MQ客?端?用上下文?境   
             MQEnvironment.hostname = props.getProperty("mqHostName"); // 服?器ip地址   
             MQEnvironment.port = Integer.parseInt(props.getProperty("mqPort")); // 服?器MQ服?端口   
             MQEnvironment.CCSID = Integer.parseInt(props.getProperty("mqCCSID")); // 服?器MQ服?使用的??   
             MQEnvironment.channel = props.getProperty("mqChannel"); // 服?器?接通道名   
             MQEnvironment.userID = props.getProperty("mqUserName"); // MQ服?用?名   
             MQEnvironment.password = props.getProperty("mqPassword");   
  
             // ?接?列管理器   
             MQQueueManager qMgr = new MQQueueManager(props.getProperty("mqQManager"));   
             int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;   
             // 打?MQ?列   
             MQQueue q = qMgr.accessQueue(props.getProperty("mqLocalOutQueue"), openOptions);   
             //FileInputStream fins = new FileInputStream(new File(strExtraSendXmlFileName));   
             InputStream fins = ClassLoader.getSystemResourceAsStream(strExtraSendXmlFileName);   
             byte[] data = new byte[fins.available()];   
             fins.read(data);   
             fins.close();   
             MQMessage msg = new MQMessage();   
             msg.write(data);   
             // 放入消息   
             q.put(msg);   
             // ???列   
             q.close();   
             // ???列管理器   
             qMgr.disconnect();   
         } catch (MQException e) {   
             logger.error(e);   
             e.printStackTrace();   
         } catch (Exception e) {   
             logger.error(e);   
             e.printStackTrace();   
         }   
     }   
  
     public void recieve() {   
         // MQ接收   
         丝袜破了有美女肉体免费观看| 国产日韩欧美国产欧美日韩| 黑人巨大精品欧美一区二区区| 草草视频精品在线观看| 激情内射日本一区二区三区| av中文字幕一区二区三区在线| 人妻久久这里只有精品| 日本午夜免费啪视频在线| 91欧美日韩精品在线| 中文字日产幕码三区国产| 色偷偷偷拍视频在线观看| 国产精品成人又粗又长又爽| 乱女午夜精品一区二区三区| 久热青青草视频在线观看| 色哟哟哟在线观看视频| 亚洲免费黄色高清在线观看| 日本精品免费在线观看| 黄片在线观看一区二区三区| 翘臀少妇成人一区二区| 欧美大黄片在线免费观看| 熟女乱一区二区三区四区| 日韩精品亚洲精品国产精品| 欧美亚洲综合另类色妞| 成人午夜在线视频观看| 高跟丝袜av在线一区二区三区| 亚洲中文字幕有码在线观看| 欧美黑人在线精品极品| 老司机亚洲精品一区二区| 日本加勒比在线观看不卡| 综合久综合久综合久久| 国产内射一级一片内射高清视频| 欧美一区二区三区99| 婷婷基地五月激情五月| 国产福利一区二区三区四区| 中文字幕欧美精品人妻一区| 亚洲专区中文字幕在线| 亚洲中文字幕在线观看黑人| 欧美做爰猛烈叫床大尺度| 日韩人妻一区二区欧美| 我想看亚洲一级黄色录像| 日韩精品一级一区二区|