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
}