MassTransit快速入门App不起作用

我在学习MassTransit。我已经通过NuGet安装了MassTransit.RabbitMQ 3.3.5版。我已经安装了Erlang 18.0 *和RabbitMQ 3.6.3（* Erlang版本19.0对RabbitMQ 3.6.3不稳定）。我发现了一个“快速入门”的MassTransit程序here，并修正了一点点typeo后，让它编译。但是，当我执行该程序时，发布的消息“YourMessage”不由处理程序处理！ RabbitMQ管理插件UI显示有一个“test_queue”队列，其中有1条消息。它仍然存在，未经处理。这里发生了什么？我在Windows 7上运行，RabbitMQ服务正在运行。MassTransit快速入门App不起作用

using MassTransit; 
using System; 

namespace MassTransitPOC.Trivial 
{ 
    public class YourMessage 
    { 
     public string Text { get; set; } 
    } 

    public class Program 
    { 
     public static void Main() 
     { 
      var bus = Bus.Factory.CreateUsingRabbitMq(sbc => 
      { 
       var host = sbc.Host(new Uri("rabbitmq://localhost"), h => 
       { 
        h.Username("guest"); 
        h.Password("guest"); 
       }); 

       sbc.ReceiveEndpoint(host, "test_queue", ep => 
       { 
        ep.Handler<YourMessage>(context => 
        { 
         return Console.Out.WriteLineAsync($"Received: {context.Message.Text}"); 
        }); 
       }); 
      }); 

      bus.Start(); 

      bus.Publish(new YourMessage { Text = "Hi" }); 

      bus.Stop(); 
     } 
    } 
}

来源

2016-07-28 Andy

我跑你的代码，并得到它通过更换从接收终端代码的工作：

sbc.ReceiveEndpoint(host, "test_queue", ep => 
{ 
    ep.Handler<YourMessage>(context => 
    { 
     return Console.Out.WriteLineAsync($"Received: {context.Message.Text}"); 
    }); 
});

...以下...

sbc.ReceiveEndpoint(host, "test_queue", ep => 
{ 
    ep.Handler<YourMessage>(context => 
     Console.Out.WriteLineAsync($"Received: {context.Message.Text}")); 
    }); 
}

看看是否能工程为你？

（RabbitMQ的：3.6.2 /二郎：OTP 18）

来源

2016-07-30 19:24:17

感谢您的回复，但您的代码除了组成处理程序的llambda表达式的样式外没有任何更改;它仍然不起作用。 – Andy

看来，bus.Stop（）调用正在取得太快我的机器上。如果我在.Publish和.Stop之间添加以下内容，则会收到消息。如果没有这段代码，发布的消息就不会被消耗。

Console.WriteLine("Press any key to exit"); 
Console.ReadKey();

来源

2016-08-01 16:56:42 Andy

MassTransit快速入门App不起作用

回答

相关问题