检测MSMQ错误

Question

我有以下代码(逐字)，希望生成错误：

using System.Messaging;

namespace MsmqTest
{
    class Program
    {
        static void Main()
        {
            string invalidQueue = @"FormatName:DIRECT=OS:sometrahsname\private$\anothertrahsname";
            Enqueue("test",invalidQueue);

        }

        private static void Enqueue(object o, string queueName)
        {
            using (MessageQueue msmq = new MessageQueue(queueName))
            using (MessageQueueTransaction transaction = new MessageQueueTransaction())
            {
                msmq.DefaultPropertiesToSend.Recoverable = true;
                transaction.Begin();
                msmq.Send(new Message(o), transaction);
                transaction.Commit();
            }
        }
    }
}

在这里，我们向不存在的服务器上的队列发送一条消息。我希望得到一个迹象，表明出了什么问题。我一点也不明白。如何检查此场景中的错误？

注意:为了运行上面的代码，您需要在计算机上安装MSMQ。

Answer 1

在我的一个应用程序中，我遇到了这个问题。MSDN记录了在MessageQueue.Send中，消息可能被发送到死信队列，而不会引发异常。这就是你现在所经历的。我所做的就是检查队列是否存在。

using System;
using System.Messaging;

namespace MsmqTest
{
    class Program
    {
        static void Main(string[] args)
        {
            string invalidQueue = @"FormatName:DIRECT=OS:sometrahsname\private$\anothertrahsname";
            Enqueue("test", invalidQueue);
        }

        private static void Enqueue(object o, string queueName)
        {
            try
            {
                MessageQueue msmq = null;
                //check if queueName exists
                //it also validates if you have access to MSMQ server
                if (!MessageQueue.Exists(queueName))
                {
                    msmq = MessageQueue.Create(queueName);

                    //you can also set the permission here
                    //because the other application that may be reading
                    //has different account with the application that created the queue
                    //set to Everyone for demonstration purposes
                    msmq.SetPermissions("Everyone", MessageQueueAccessRights.FullControl);
                }
                else
                {
                    msmq = new MessageQueue(queueName);
                }

                using (msmq)
                {
                    using (MessageQueueTransaction transaction = new MessageQueueTransaction())
                    {
                        msmq.DefaultPropertiesToSend.Recoverable = true;
                        transaction.Begin();
                        msmq.Send(new Message(o), transaction);
                        transaction.Commit();
                    }
                }
            }catch(Exception)
            {
                //handle error here
            }
        }
    }
}