Действительно ли возможно потерять сообщения с помощью MSMQ MessageQueue. Быстрый взгляд с тайм-аутом?

У меня в настоящее время есть проблема потери сообщения. Эта ошибка редко происходит, но, оказывается, достаточно часто является раздражающей. Вот контекст проблемы:

• Я включил журнал сообщения на goldmine_service_queue, MSMQ на сервере Windows 2003.
• Я могу доказать, что сообщение вставляется в goldmine_service_queue, так как сообщение появляется в журнале сообщения. Эта информация дает информацию синхронизации о том, когда сообщение исчезло.
• Регистрирующиеся функции используют http://logging.apache.org/log4net/index.html
• Журналы не показывают ошибки.
• Функция рабочего (показанный ниже) выполняется в потоке службы Windows. Это ответственно за заглядывание на сообщения (объекты работы) от очереди и обработки их.
• От журналов я сильно подозреваю, что моя проблема могла бы коснуться MessageQueue. Посмотрите и приведите к таймауту поведения.

Действительно ли это возможно для тайм-аута, и сообщение получают для появления одновременно? Существует ли лучший способ для меня обработать сервисную остановку проверить, чтобы помочь избежать этой ошибки?

        private void workerFunction()
    {

        logger.Info("Connecting to queue: " + Settings.Default.goldmine_service_queue);
        MessageQueue q = new MessageQueue(Settings.Default.goldmine_service_queue);
        q.Formatter = new ActiveXMessageFormatter();

        while (serviceStarted)
        {

            Message currentMessage = null;

            try
            {
                currentMessage = q.Peek(new TimeSpan(0,0,30));
            }
            catch (System.Messaging.MessageQueueException mqEx)
            {
                if (mqEx.ToString().Contains("Timeout for the requested operation has expired"))
                {
                    logger.Info("Check for service stop request");
                }
                else
                {
                    logger.Error("Exception while peeking into MSMQ: " + mqEx.ToString());
                }
            }
            catch (Exception e)
            {
                logger.Error("Exception while peeking into MSMQ: " + e.ToString());
            }

            if (currentMessage != null)
            {

                logger.Info(currentMessage.Body.ToString());
                try
                {
                    ProcessMessage(currentMessage);
                }
                catch (Exception processMessageException)
                {
                    logger.Error("Error in process message: " + processMessageException.ToString());
                }

                //Remove message from queue.
                logger.Info("Message removed from queue.");
                q.Receive();
                //logPerformance(ref transCount, ref startTime);
            }


        }//end while

        Thread.CurrentThread.Abort();

    }