2010-03-11 45 views
1

我已經以非常相似的方式設置了關於它的博客文章,但是在啓動時遇到了一個隊列錯誤。Rhino.ServiceBus爲什麼不自動創建我的所有隊列?

msmq://localhost/colin_console_queue不會由我的程序自動創建。

我很確定我只是沒有做正確的事,但我不知道我省略了什麼。

我確實發現了'DisableAutoQueueCreation'屬性,我試圖在各種配置元素上將它設置爲false,我甚至發現它作爲RhinoServiceBusFacility上的一個屬性可用,所以我嘗試將它設置爲那裏。不幸的是,似乎沒有任何工作。

如果我更改這兩個網址指向相同的隊列應用程序基本上可以工作,但我相當確信這不是我應該做的。我查看了星巴克示例應用程序以瞭解它的功能,但似乎在代碼中使用硬編碼路徑進行了大量設置。

<facilities> 
    <facility id="rhino.esb"> 
    <bus threadCount="1" numberOfRetries="5" endpoint="msmq://localhost/colin_console_queue_bus" 
     logEndpoint="msmq://localhost/colin_console_queue_bus.log" /> 
    <messages> 
     <add name="ConsoleApplication1" endpoint="msmq://localhost/colin_console_queue" /> 
    </messages> 
    </facility> 
</facilities> 

這是我用來測試如何使用隊列的測試程序。

static void Main(string[] args) 
    { 
     var container = new WindsorContainer(new XmlInterpreter()); 
     container.Kernel.AddFacility("rhino.esb", new RhinoServiceBusFacility()); 
     if (args.Length > 0) 
     { 
      var bus = container.Resolve<IStartableServiceBus>(); 
      bus.Start(); 
      bus.Send(new EmailMessage { Message = args[0], To = "test" }); 
      bus.Dispose(); 
     } 
     else 
     { 
      container.Register(AllTypes.FromAssembly(Assembly.GetExecutingAssembly()).BasedOn(typeof(IMessageConsumer))); 
      var bus = container.Resolve<IStartableServiceBus>(); 
      bus.Start(); 
      Console.ReadLine(); 
      Console.WriteLine("Bus stopped"); 
      bus.Dispose(); 
     } 
    } 

以下是錯誤我得到的,

Unhandled Exception: System.Transactions.TransactionException: Failed to send message to Uri: msmq://colin-pc/colin_console_queue ---> Rhino.ServiceBus.Exceptions.TransportException: The queue msmq://colin-pc/colin_console_queue does not exists 
    at Rhino.ServiceBus.Msmq.OpenedQueue..ctor(QueueInfo info, MessageQueue queue, String url, Nullable`1 transactional) in D:\Work\rhino-esb\Rhino.ServiceBus\Msmq\OpenedQueue.cs:line 24 
    at Rhino.ServiceBus.Msmq.QueueInfo.Open(QueueAccessMode access, IMessageFormatter formatter) in D:\Work\rhino-esb\Rhino.ServiceBus\Msmq\QueueInfo.cs:line 71 
    at Rhino.ServiceBus.Msmq.QueueInfo.Open(QueueAccessMode access) in D:\Work\rhino-esb\Rhino.ServiceBus\Msmq\QueueInfo.cs:line 63 
    at Rhino.ServiceBus.Msmq.MsmqTransport.SendMessageToQueue(Message message, Endpoint endpoint) in D:\Work\rhino-esb\Rhino.ServiceBus\Msmq\MsmqTransport.cs:line 303 

回答

3

感謝Ayende(通過電子郵件),答案證明是因爲您聽的隊列(在巴士標籤中提到的隊列)是您自動負責創建的唯一隊列。

雖然我的示例程序相當有缺陷,但是我完全重寫了一些內容,並使用單向隊列來確保正確理解它(好吧,我想我是這麼做的!)。我或許會在某個時候提出這個例子,因爲我一定會有點困難。

0

好,在一般的web應用程序不應該的東西作爲抵達迪南到基礎設施的消息隊列排隊服務器的配置做行政訴訟。真。正常的行政指導 - 這就是爲什麼程序員可能不認爲有人會嘗試這種做法。 )

看到了,可能會有更多的設置你的隊列比你想象的;)就像配置它。

手動設置隊列。

+0

對不起,我沒有試圖從網站配置隊列。那是一些關於我在做什麼的不必要的「背景」信息,所以我已經從問題中刪除了它。 – 2010-03-11 10:00:40

相關問題