PutMessageOnQueue
GetMessageOffQueue
public class MQSeries{ string queueName; string queueManagerName; MQQueue queue; MQMessage queueMessage; MQQueueManager queueManager; public MQSeries() { queueName = "TESTQ"; queueManagerName = "TESTQM"; queueManager = new MQQueueManager(queueManagerName); } public void PutMessageOnQueue(string message) { try { queue = queueManager.AccessQueue(queueName, MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING); queueMessage = new MQMessage(); queueMessage.WriteString(message); queueMessage.Format = MQC.MQFMT_STRING; queue.Put(queueMessage); } catch (MQException mqexp) { Console.WriteLine("MQSeries Exception: " + mqexp.Message); } } public string GetMessageOffQueue() { string message = ""; queue = queueManager.AccessQueue(queueName, MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING); queueMessage = new MQMessage(); queueMessage.Format = MQC.MQFMT_STRING; try { queue.Get(queueMessage); message = queueMessage.ReadString(queueMessage.MessageLength); } catch (MQException MQExp) { Console.WriteLine("MQQueue::Get ended with " + MQExp.Message); } return message; }}
Copyright © 2006-2008 Corey Goldberg
Disclaimer The opinions expressed herein are my own personal opinions and do not represent my employer's view in any way.