StreamReader sr = File.OpenText("\\abc.xml"); string s = sr.Read().ToString(); MQQueueManager mqQMgr; try { mqQMgr = new MQQueueManager("QM_APPLE", "SYSTEM.DEF.SVRCONN", "127.0.0.1(1414)"); MQQueue requestQueue = mqQMgr.AccessQueue("Q1", MQC.MQOO_OUTPUT // open queue for output + MQC.MQOO_FAIL_IF_QUIESCING); // but not if // MQM stopping MQQueue responseQueue = mqQMgr.AccessQueue("Q2", MQC.MQOO_INPUT_AS_Q_DEF // open queue for input + MQC.MQOO_FAIL_IF_QUIESCING); MQMessage requestMessage = new MQMessage(); requestMessage.WriteString(s); requestMessage.Format = MQC.MQFMT_STRING; requestMessage.MessageType = MQC.MQMT_REQUEST; requestMessage.Report = MQC.MQRO_COPY_MSG_ID_TO_CORREL_ID; requestMessage.ReplyToQueueName = "Q2"; requestMessage.ReplyToQueueManagerName = "MQ_APPLE"; requestQueue.Put(requestMessage); //read response message from IBM Queue MQMessage responseMessage = new MQMessage(); MQPutMessageOptions pmo = new MQPutMessageOptions(); pmo.Options = MQC.MQPMO_NONE; if ((requestMessage.Report & MQC.MQRO_PASS_MSG_ID) == MQC.MQRO_PASS_MSG_ID) responseMessage.MessageId = requestMessage.CorrelationId; else // Assume MQRO_NEW_MSG_ID pmo.Options = MQC.MQPMO_NEW_MSG_ID; if ((requestMessage.Report & MQC.MQRO_PASS_CORREL_ID) == MQC.MQRO_PASS_CORREL_ID) responseMessage.CorrelationId = requestMessage.CorrelationId; else // Assume MQRO_COPY_MSG_ID_TO_CORREL_ID responseMessage.CorrelationId = requestMessage.MessageId; responseMessage.MessageType = MQC.MQMT_REPLY; responseMessage.WriteString("Done"); responseQueue.Put(responseMessage); if (responseQueue.OpenStatus) responseQueue.Close(); //if (mqQMgr.ConnectionStatus) // mqQMgr.Disconnect(); } catch (MQException mqe) { lblMessage.Text = mqe.Reason.ToString(); goto Wuta; }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)