Почему Rhino не работает.ServiceBus автоматически создает все мои очереди?
-
19-09-2019 - |
Вопрос
Я настроил все примерно так же, как в сообщениях в блоге об этом, но при запуске я получаю сообщение об ошибке в отношении одной из очередей.
В 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
Решение
Благодаря Ayende (по электронной почте) выясняется, что ответ заключается в том, что прослушиваемая вами очередь (та, что указана в теге bus) - единственная, за автоматическое создание которой вы несете ответственность.
Однако мой пример программы довольно испорчен, поэтому я полностью переписал все и использовал одностороннюю очередь, чтобы убедиться, что я понял это правильно (ну, я думаю, что понимаю!).Возможно, в какой-то момент я приведу этот пример, потому что мне, конечно, было немного трудно разобраться во всем этом.
Другие советы
Ну, в общем случае веб-приложение не должно выполнять административные действия над чем-то столь центральным для инфраструктуры, как конфигурация очереди сообщений сервера очередей.Действительно.Обычные административные инструкции - вот почему программисты, вероятно, не думали, что кто-то вообще попытается это сделать.
Видите, в настройке очереди u может быть нечто большее, чем вы думаете ;) Например, ее настройка.
Настройте очереди вручную.