如何使用 MassTransit InMemory？

如何解决如何使用 MassTransit InMemory？

我想通过接口注册消费者，发送消息，从容器中通过接口初始化它，然后消费：

public sealed class TestConsumer<T> : IConsumer<T>
    where T : class
{
    private readonly Func<ConsumeContext<T>,Task> _onConsume;
    private readonly EventWaitHandle _handle;
    public TestConsumer(Func<ConsumeContext<T>,Task> onConsume)
    {
        _onConsume = onConsume;
        _handle = new EventWaitHandle(false,EventResetMode.ManualReset);
    }

    public async Task Consume(ConsumeContext<T> context)
    {
        try
        {
            await _onConsume(context).ConfigureAwait(false);
        }
        finally
        {
            _handle.Set();
        }
    }

    public async Task GetTask()
    {
        while (!_handle.WaitOne(0))
            await Task.Delay(100);
    }
}


public class MyRequest { }

[TestFixture]
public class ConsumerTests
{
    [Test]
    public async Task Test()
    {
        var services = new ServiceCollection();
        var tc = new TestConsumer<MyRequest>(async (c) => Console.WriteLine("request"));
        services.AddSingleton<IConsumer<MyRequest>>(tc);
        services.AddSingleton<IBusControl>(x => Bus.Factory.CreateUsingInMemory(cfg =>
        {
            cfg.ReceiveEndpoint("foobar",c => { c.Consumer<IConsumer<MyRequest>>(x); });
        }));

        var sp = services.BuildServiceProvider();

        await sp.GetRequiredService<IBusControl>().StartAsync();

        //and how do I send it?
        //this will obviously not work with Uri!!!
        var sendEndpoint = await sp.GetRequiredService<IBusControl>().GetSendEndpoint(new Uri("foobar",UriKind.Relative));
        await sendEndpoint.Send(new MyRequest());

        await tc.GetTask();
        Console.WriteLine("done");
    }
}

老实说，缺乏文档让我发疯。有线束之类的东西，但它只有在你将 DI 容器扔进垃圾桶或编写大量适配器时才有效。

如何使用 InMemory 并将其与 Send 方法中完全不兼容的 Uri 结合起来？