NServiceBus 测试客户端未收到消息

我对 NService Bus 非常陌生，所以我正在尝试使用 LearningPersistence 让它与一个简单的测试解决方案一起工作，显然这很快就会改变！

所以我有3个项目：

IceDataExtractor - 发送消息的客户端

IceProcessManager - 处理消息

消息- 包含单个消息类消息

我正在使用 NServiceBus.Bootstrap.WindowsService 2.0.1 生成的标准代码

这是我用来获取样本的页面

然后我修改如下

冰数据提取器

private async Task AsyncOnStart()
{
    try
    {
        var endpointConfiguration = new EndpointConfiguration("IceDataExtractor");
        var transport = endpointConfiguration.UseTransport<LearningTransport>();
        transport.Routing().RouteToEndpoint(typeof(TestMessage), "IceProcessManager");
        endpointConfiguration.UseSerialization<JsonSerializer>();
        //TODO: optionally choose a different error queue. Perhaps on a remote machine
        // https://docs.particular.net/nservicebus/recoverability/
        endpointConfiguration.SendFailedMessagesTo("error");
        //TODO: optionally choose a different audit queue. Perhaps on a remote machine
        // https://docs.particular.net/nservicebus/operations/auditing
        endpointConfiguration.AuditProcessedMessagesTo("audit");
        endpointConfiguration.DefineCriticalErrorAction(OnCriticalError);
        //TODO: For production use select a durable persistence.
        // https://docs.particular.net/nservicebus/persistence/
        endpointConfiguration.UsePersistence<LearningPersistence>();

        //TODO: For production use script the installation.
        endpointConfiguration.EnableInstallers();

        endpointConfiguration.Conventions()
            .DefiningCommandsAs(t => t.Namespace != null && t.Namespace.StartsWith("Messages") &&
                                     t.Namespace.EndsWith("Commands"));

        endpoint = await Endpoint.Start(endpointConfiguration)
            .ConfigureAwait(false);
        PerformStartupOperations();

        **var testMessage = new TestMessage {Id = Guid.NewGuid()};
        await endpoint.Send(testMessage).ConfigureAwait(false);**
    }
    catch (Exception exception)
    {
        logger.Fatal("Failed to start", exception);
        Environment.FailFast("Failed to start", exception);
    }
}

冰过程管理器

private async Task AsyncOnStart()
{
    try
    {
        var endpointConfiguration = new EndpointConfiguration("IceDataExtractor");
        var transport = **endpointConfiguration.UseTransport<LearningTransport>();
        transport.Routing().RouteToEndpoint(typeof(TestMessage), "IceProcessManager");**
        endpointConfiguration.UseSerialization<JsonSerializer>();
        //TODO: optionally choose a different error queue. Perhaps on a remote machine
        // https://docs.particular.net/nservicebus/recoverability/
        endpointConfiguration.SendFailedMessagesTo("error");
        //TODO: optionally choose a different audit queue. Perhaps on a remote machine
        // https://docs.particular.net/nservicebus/operations/auditing
        endpointConfiguration.AuditProcessedMessagesTo("audit");
        endpointConfiguration.DefineCriticalErrorAction(OnCriticalError);
        //TODO: For production use select a durable persistence.
        // https://docs.particular.net/nservicebus/persistence/
        endpointConfiguration.UsePersistence<LearningPersistence>();

        //TODO: For production use script the installation.
        endpointConfiguration.EnableInstallers();

        **endpointConfiguration.Conventions()
            .DefiningCommandsAs(t => t.Namespace != null && t.Namespace.StartsWith("Messages") &&
                                     t.Namespace.EndsWith("Commands"));**

        endpoint = await Endpoint.Start(endpointConfiguration)
            .ConfigureAwait(false);
        PerformStartupOperations();

        var testMessage = new TestMessage {Id = Guid.NewGuid()};
        await endpoint.Send(testMessage).ConfigureAwait(false);
    }
    catch (Exception exception)
    {
        logger.Fatal("Failed to start", exception);
        Environment.FailFast("Failed to start", exception);
    }
}

测试消息类

using System;

namespace Messages.Commands
{
    public class TestMessage
    {
        public Guid Id { get; set; }
    }
}

这一切都编译并运行良好，除了我认为无关紧要的性能警告

我有一个消息处理程序

测试消息处理程序

using System;
using System.Threading.Tasks;
using Messages.Commands;
using NServiceBus;

namespace IceProcessManager
{
    public class TestMessageHandler : IHandleMessages<TestMessage>
    {
        public Task Handle(TestMessage message, IMessageHandlerContext context)
        {
            Console.WriteLine("Handled TEst MEssage ID:{0}", message.Id);

            return Task.CompletedTask;
        }
    }
}

正如您从屏幕截图中看到的，IceProcessManager 没有收到任何消息。我究竟做错了什么？我最初认为我发送消息过早，即在 ProcessManager 启动并运行之前，但这不是问题，因为如果我让 ProcessManager 运行（即从资源管理器运行）然后运行提取器，则不会收到任何消息

理想情况下，我想发送大量消息来测试这个，但我还不熟悉异步的东西！

有人可以帮忙吗？

保罗