/// /// Put the massages into the Queue /// mqPutMsgOpts = new MQPutMessageOptions(); mqPutMsgOpts.Version = MQC.MQPMO_VERSION_2; mqPutMsgOpts.Options = MQC.MQPMO_LOGICAL_ORDER | MQC.MQPMO_SYNCPOINT; mqMsg = new MQMessage(); mqMsg.WriteBytes(XML_message); mqMsg.MessageId = MQC.MQMI_NONE; mqMsg.CorrelationId = StrToByteArray("cor0"); mqMsg.GroupId = MQC.MQGI_NONE; mqMsg.Version = MQC.MQMD_VERSION_2; mqMsg.MessageFlags = MQC.MQMF_MSG_IN_GROUP; try { mqQueue.Put(mqMsg, mqPutMsgOpts); mqQMgr.Commit(); } catch (MQException mqe) { LogAusgabe(String.Format("Beim Einreihen der Nachricht ist ein Fehler aufgetreten ({0})!", mqe.Message), 1); return false; } mqMsg = new MQMessage(); mqMsg.WriteBytes(BAL_message); mqMsg.MessageId = MQC.MQMI_NONE; mqMsg.CorrelationId = StrToByteArray("cor1"); mqMsg.Version = MQC.MQMD_VERSION_2; mqMsg.MessageFlags = MQC.MQMF_MSG_IN_GROUP; try { mqQueue.Put(mqMsg, mqPutMsgOpts); mqQMgr.Commit(); } catch (MQException mqe) { LogAusgabe(String.Format("Beim Einreihen der Nachricht ist ein Fehler aufgetreten ({0})!", mqe.Message), 1); return false; } mqMsg = new MQMessage(); mqMsg.WriteBytes(END_message); mqMsg.MessageId = MQC.MQMI_NONE; mqMsg.CorrelationId = StrToByteArray("cor2"); mqMsg.Version = MQC.MQMD_VERSION_2; mqMsg.MessageFlags = MQC.MQMF_MSG_IN_GROUP | MQC.MQMF_LAST_MSG_IN_GROUP; try { mqQueue.Put(mqMsg, mqPutMsgOpts); mqQMgr.Commit(); } catch (MQException mqe) { LogAusgabe(String.Format("Beim Einreihen der Nachricht ist ein Fehler aufgetreten ({0})!", mqe.Message), 1); return false; }