使用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