2017-09-25 71 views
0

所以我一直在嘗試使用內存中功能編寫一個測試公共交通的測試。我想知道人們的做法是等待消費者執行。在下面的例子中使用睡眠,或者我也嘗試了一個while循環,但不是任何一個迷,任何更好的想法?我基本上想檢查消費者是否被執行。Masstransit內存測試等待消費者執行

[Fact] 
public async Task SomeTest() 
{ 
    var busControl = Bus.Factory.CreateUsingInMemory(cfg => 
    { 
     cfg.ReceiveEndpoint("commands", ec => 
     { 
      ec.LoadFrom(context); 
     }); 
    }); 
    var address = new Uri(bus.Address, "commands") 
    await sendEndpoint.Send(MyExampleCommand()); 
    Thread.Sleep(2000); 

    //Check nsubstitute mock received 
} 

回答