Por Rhino.ServiceBus não está criando automaticamente todos os meus filas?
-
19-09-2019 - |
Pergunta
Eu tenho coisas configuração de uma forma muito semelhante aos posts sobre isso, mas eu estou recebendo um erro quando no arranque sobre uma das filas.
O msmq://localhost/colin_console_queue
não são criados automaticamente pelo meu programa.
Estou bastante certo que eu não sou apenas fazendo algo certo, mas eu não sei o que eu omitido.
eu descobri um atributo 'DisableAutoQueueCreation' e eu tentei defini-la como falsa sobre os vários elementos de configuração e eu mesmo descobri que era disponível como uma propriedade na RhinoServiceBusFacility
então eu tentei defini-lo lá também. Infelizmente, nenhum dos que parecia trabalho.
Se eu mudar as duas URLs para apontar para a mesma fila o aplicativo funciona basicamente mas estou bastante certo de que não é o que eu deveria fazer. Olhei para o exemplo aplicativo Starbucks para ver o que ele faz, mas parece fazer um monte de configuração utilizando caminhos codificados no código.
<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>
Aqui está o meu programa de teste que estou usando para descobrir como usar a Fila.
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();
}
}
Aqui está o erro que recebo,
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
Solução
Graças a Ayende (via e-mail) a resposta acaba por ser porque a fila você ouvir (o mencionado na etiqueta de ônibus) é o único que você é responsável por criar automaticamente.
O meu programa de exemplo é bastante falho embora assim que eu reescrevi coisas completamente e fez uso da uma maneira fila para garantir que eu entendi corretamente (bem, eu acho que eu faço!). Eu talvez vou colocar o exemplo em algum momento, porque eu certamente tinha um pouco de dificuldade grokking tudo.
Outras dicas
Bem, em uma aplicação geral web não deve fazer administrativas em algo tão ccentral à infra-estrutura como a configuração de enfileiramento de mensagens de um servidor de filas. Sério. guidleines administrativas normais -. que é por isso que os programadores provavelmente não pensam someoen sequer tentar isso
Veja, pode haver mais para definir u pThe fila do que você pensa de;). Como configurá-lo
Configurar as filas manualmente.