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
}