檢測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 
      } 
     } 
    } 
}