Почему Rhino.ServiceBus не создает автоматически все мои очереди? - PullRequest
Новая
       35

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

1 голос
/ 11 марта 2010

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

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

Ответы [ 2 ]

3 голосов
/ 12 марта 2010

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

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

0 голосов
/ 11 марта 2010

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

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

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

...