MSMQ 消息队列插入删除操作方法

【实例截图】

 /// <summary>
        /// 初始化MSMQ队列 
        /// </summary>
        private void InitActiveEventMSMQ()
        {
            if (MessageQueue.Exists(strmsmqWord))
            {
                m_activeEventMSMQ = new MessageQueue(strmsmqWord);
            }
            else
            {
                m_activeEventMSMQ = MessageQueue.Create(strmsmqWord);
                m_activeEventMSMQ.SetPermissions("Everyone", MessageQueueAccessRights.FullControl);
            }
            m_activeEventMSMQ.Formatter = new XmlMessageFormatter(new[] { typeof(NotificationEntity) });

        }

 

 

 public void DeleMemqInfo()
        {
            dtStart = DateTime.Now;
            lblstart.Text = DateTime.Now.ToString("yyyy-MM-dd hh:m:ss");
            this._Logger.InfoFormat("测试信息--开始");
            try
            {
                if (m_activeEventMSMQ == null) return;
                string strInfo = string.Empty;
                while (m_activeEventMSMQ.GetAllMessages().Length > 0)
                {
                    MessageEnumerator msgEnumerator = m_activeEventMSMQ.GetMessageEnumerator2();
                    while (msgEnumerator.MoveNext(m_timeSpan))
                    {
                        System.Messaging.Message msg = m_activeEventMSMQ.PeekById(msgEnumerator.Current.Id);
                        if (msg == null) break;                     
                        m_activeEventMSMQ.ReceiveById(msg.Id);                     
                    }
                }
            }
            catch (Exception ex1)
            {
                _Logger.Error(ex1);
            }

            this._Logger.InfoFormat("测试信息--结束");
            dtEnd = DateTime.Now;
            lblEnd.Text = DateTime.Now.ToString("yyyy-MM-dd hh:m:ss");
            TimeSpan ts = dtEnd - dtStart;
            lblResult.Text = "用时秒:" Math.Round(ts.TotalSeconds, 2).ToString();
        }