MQTest开发(c#).doc

using System;using System.Collections.Generic;using System.Linq;using System.Text;using IBM.WMQ;namespace MQExample / / Author: Reza Servia / Name: MQTest.cs / Description: / MQ Manager Class / Put/Get Messages To/From Local Queue / public class MQTest MQQueueManager queueManager; MQQueue queue; MQMessage queueMessage; MQPutMessageOptions queuePutMessageOptions; MQGetMessageOptions queueGetMessageOptions; static string SendQueueName; static string ReceiveQueueName; static string QueueManagerName; static string ChannelInfo; string channelName; string transportType; string connectionName; string message; public MQTest() /Initialisation /* QueueManagerName = QM_TEST; QueueName = QM_TEST.LOCAL.ONE; ChannelInfo = SVRCONN/TCP/localhost(1424); */ / / Connect to MQ Server / / Queue Manager Name / Channel Information / public string ConnectMQ(string strQueueManagerName, string strChannelInfo) QueueManagerName = strQueueManagerName; ChannelInfo = strChannelInfo; char separator = / ; string ChannelParams; ChannelParams = ChannelInfo.Split(separator); channelName = ChannelParams0; transportType = ChannelParams1; connectionName = ChannelParams2; string strReturn = ; try queueManager = new MQQueueManager(QueueManagerName, channelName, connectionName); strReturn = Connected Successfully; catch (MQException exp) strReturn = Exception: + exp.Message; catch (Exception exp) strReturn = Exception: + exp.Message; return strReturn; / / Write Message to Local Queue / / Text Message / Queue Name / public string WriteLocalQMsg(string strInputMsg, string strQueueName) string strReturn = ; SendQueueName = strQueueName; try queue = queueManager.AccessQueue(SendQueueName, MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING); message = strInputMsg; queueMessage = new MQMessage(); queueMessage.WriteString(message); queueMessage.Format = MQC.MQFMT_STRING; queuePutMessageOptions = new MQPutMessageOptions(); queue.Put(queueMessage, queuePutMessageOptions); strReturn = Message sent to the queue successfully; catch (MQException MQexp) strReturn = Exception: + MQexp.Message; catch (Exception exp) strReturn = Exception: + exp.Message; return strReturn; / / Write Message to Local Queue / / Text Message / public string WriteLocalQMsg(string strInputMsg) string strReturn = ; try queue = queueManager.AccessQueue(SendQueueName, MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING ); message = strInputMsg; queueMessage = new MQMessage(); queueMessage.WriteString(message); queueMessage.Format = MQC.MQFMT_STRING; queuePutMessageOptions = new MQPutMessageOptions(); queue.Put( queueMessage, queuePutMessageOptions); strReturn = Message sent to the queue successfully; catch (MQException MQexp) strReturn = Exception: + MQexp.Message; catch (Exception exp) strReturn = Exception: + exp.Message; return strReturn; / / Read Message from Local Queue / / Queue Name / Text Message public string ReadLocalQMsg(string strQueueName) string strReturn = ; ReceiveQueueName = strQueueName; try queue = queueManager.AccessQueue(ReceiveQueueName, MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING); queueMessage = new MQMessage(); queueMessage.Format = MQC.MQFMT_STRING; queueGetMessageOptions = new MQGetMessageOptions(); queue.Get(queueMessage, queueGetMessageOptions); strReturn = queueMessage.ReadString(q