package?com.rtmap.traffic.sync.ckg.util;

import?java.io.FileWriter;
import?java.io.IOException;
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.MQPutMessageOptions;
import?com.ibm.mq.MQQueue;
import?com.ibm.mq.MQQueueManager;

public?class?MQUtils?{

	private?MQQueueManager?qMgr;?//?隊列管理器名稱
	private?MQQueue?qQueue;?//?消息通道
	private?String?qmanager;?//?QueueManager名
	private?String?hostName;?//?主機名
	private?int?port;?//?端口號
	private?String?qname;?//?本地隊列
	private?String?channel;?//?連接通道
	private?int?ccsid;?//?字符集
	
	public?String?getQmanager（）?{
		return?qmanager;
	}

	public?void?setQmanager（String?qmanager）?{
		this.qmanager?=?qmanager;
	}

	public?String?getHostName（）?{
		return?hostName;
	}

	public?void?setHostName（String?hostName）?{
		this.hostName?=?hostName;
	}

	public?int?getPort（）?{
		return?port;
	}

	public?void?setPort（int?port）?{
		this.port?=?port;
	}

	public?String?getQname（）?{
		return?qname;
	}

	public?void?setQname（String?qname）?{
		this.qname?=?qname;
	}

	public?String?getChannel（）?{
		return?channel;
	}

	public?void?setChannel（String?channel）?{
		this.channel?=?channel;
	}

	public?int?getCcsid（）?{
		return?ccsid;
	}

	public?void?setCcsid（int?ccsid）?{
		this.ccsid?=?ccsid;
	}

	public?MQQueueManager?getqMgr（）?{
		return?qMgr;
	}

	public?void?setqMgr（MQQueueManager?qMgr）?{
		this.qMgr?=?qMgr;
	}

	public?MQQueue?getqQueue（）?{
		return?qQueue;
	}

	public?void?setqQueue（MQQueue?qQueue）?{
		this.qQueue?=?qQueue;
	}

	/**
	?*?發送消息
	?*/
	public?void?sendMsg（String?msgStr）?{
		try?{
			init（）;
			MQMessage?qMsg?=?new?MQMessage（）;
			qMsg.encoding?=?ccsid;
			qMsg.characterSet?=?ccsid;
			qMsg.writeString（msgStr）;
			MQPutMessageOptions?pmo?=?new?MQPutMessageOptions（）;
			qQueue.put（qMsg?pmo）;
			System.out.println（“發送成功“）;
		}?catch?（MQException?e）?{
			System.out.println（“發生了一起異常，異常原因：“?+?e.reasonCode）;
		}?catch?（IOException?e）?{
			System.out.println（“發生了一起IO異常：“?+?e.getMessage（））;
		}?finally?{?
			finalizer（）;
		}
	}
	
	/**
	?*?獲取隊列深度
	?*?@return
	?*?@throws?MQException
	?*/
	public?String?getCurrentDepth（）?throws?MQException
	{
		final?MQMessage?revMessage?=?new