Почему Rhino не работает.ServiceBus автоматически создает все мои очереди?

Question

Я настроил все примерно так же, как в сообщениях в блоге об этом, но при запуске я получаю сообщение об ошибке в отношении одной из очередей.

В msmq://localhost/colin_console_queue не создается автоматически моей программой.

Я совершенно уверен, что просто делаю что-то не так, но я не знаю, что я пропустил.

Я обнаружил атрибут 'DisableAutoQueueCreation' и попытался установить для него значение false в различных элементах конфигурации, и я даже обнаружил, что он доступен как свойство в RhinoServiceBusFacility поэтому я попробовал установить его и там.К сожалению, ничего из этого, похоже, не сработало.

Если я изменю два URL-адреса, чтобы они указывали на одну и ту же очередь, приложение в основном заработает, но я совершенно уверен, что это не то, что я должен делать.Я просмотрел пример приложения Starbucks, чтобы посмотреть, что оно делает, но, похоже, оно выполняет большую часть настроек, используя жестко закодированные пути в коде.

<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

Answer 1

Благодаря Ayende (по электронной почте) выясняется, что ответ заключается в том, что прослушиваемая вами очередь (та, что указана в теге bus) - единственная, за автоматическое создание которой вы несете ответственность.

Однако мой пример программы довольно испорчен, поэтому я полностью переписал все и использовал одностороннюю очередь, чтобы убедиться, что я понял это правильно (ну, я думаю, что понимаю!).Возможно, в какой-то момент я приведу этот пример, потому что мне, конечно, было немного трудно разобраться во всем этом.

Answer 2

Ну, в общем случае веб-приложение не должно выполнять административные действия над чем-то столь центральным для инфраструктуры, как конфигурация очереди сообщений сервера очередей.Действительно.Обычные административные инструкции - вот почему программисты, вероятно, не думали, что кто-то вообще попытается это сделать.

Видите, в настройке очереди u может быть нечто большее, чем вы думаете ;) Например, ее настройка.

Настройте очереди вручную.