private void MQRecieve()   //MQ接收函數
        {
            try
            {
                bool isWebServiceSuccess = WebServiceStart(); //通過WebService傳請求條件
                if (isWebServiceSuccess == false)
                {
                    System.Windows.Forms.MessageBox.Show("調用webservice出錯...", "提示", MessageBoxButtons.OK);
                    ThreadClose();
                    return;
                }
                using (MqConsumer mqConsumer = new MqConsumer(uri, curLogRequestCondition.destination, false, false))
                {
                    TMsgHandler callback = new TMsgHandler(RecieveData); //回調函數綁定處理接收數據的函數
                    mqConsumer.SetMsgHandler(callback);

                    mqConsumer.runConsumer();
                    while (!isStopped)
                    {
                        Thread.Sleep(5000);
                    }
                    mqConsumer.CloseMq();
                }
            }
            catch
            {
                isStopped = true;
            }
        }

protected void RecieveData(string message) //處理接收數據的函數
        {
            try
            {
                iflag++;
                if (message.IndexOf("END_") == -1)//不是END_
                {
                    dataList.Add(message);
                }
                if (message.IndexOf("END_") != -1)//接收結束
                {
                    GetLogDataEvent.Invoke(dataList);
                    dataList.Clear();
                    if (iflag == 1)
                    {
                        MessageBox.Show("沒有查到符號條件的日志信息");
                    }
                }
                else if (iflag % 1000 == 0)
                {
                    GetLogDataEvent.Invoke(dataList);
                    dataList.Clear();
                }
            }
            catch
            {
                isStopped = true;
            }
        }

 private bool WebServiceStart()
        {
            try
            {
                OSSDOM.CMT.CommonUse.LogService.LogRequest curCondition = curLogRequestCondition;
                OSSDOM.CMT.CommonUse.LogService.Service1 logService1 = new OSSDOM.CMT.CommonUse.LogService.Service1();
                logService1.Url = OSSDOM.Common.Function.PubFunction.ReadXmlFileNode("Config\\WebServiceConfig.xml", "/configuration/LogService");
                if (ServerConnState.serverConnected == false)
                {
                    logService1.Url = logService1.Url.Replace(MakeOptionDatas.MakeOptionDataInstance.proxy.strProxyIP, MakeOptionDatas.MakeOptionDataInstance.StandbyProxy.strProxyIP);
                }
                bool isTranSuccess = logService1.GetLogRequest(curCondition);
                return isTranSuccess;
            }
            catch
            {
                return false;
            }
        }