MQ工具类java

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