使用MassTransit集成测试微服务

我正在尝试围绕使用MassTransit创建的一些服务创建黑盒集成测试。服务的要点是它在MassTransit通道上接收消息，处理消息并在不同的MassTransit通道上发送消息（请注意，这不是请求 - 回复语义，而是流水线中更多的组件）：使用MassTransit集成测试微服务

IBusControl bus = Bus.Factory.CreateUsingRabbitMq(cfg => 
{ 
    var host = cfg.Host(new Uri("rabbitmq://localhost"), 
     h => 
     { 
      h.Username("guest"); 
      h.Password("guest"); 
     }); 

    cfg.ReceiveEndpoint(host, "Queue1", ep => 
    { 
     ep.Handler<ItemStarted>(context => 
     { 
      ItemFinished item = FinishMessage(context.Message); 
      context.Publish(item); 
     }); 
    }); 
}); 

bus.Start();

为了测试这个，我想我需要的是从总线接收消息的同步方式。有没有办法做到这一点：

IBusControl bus = Bus.Factory.CreateUsingRabbitMq(cfg => 
    var host = cfg.Host(new Uri("rabbitmq://localhost"), 
     h => 
     { 
      h.Username("guest"); 
      h.Password("guest"); 
     })); 

bus.Start(); 

bus.Publish(new ItemStarted()); 

// This is what does not seem to exist 
ItemFinished finished = bus.Receive<ItemFinished>(timeout : Timespan.FromSeconds(5)); 

// Assertions about finished

有没有办法直接从MassTransit收到消息，而不连接最多消费类或拉姆达？

来源

2015-10-26 Jeff Hornby