NServiceBus 测试客户端不接收消息

Question

我是 NService Bus 的新手，所以我正在尝试使用 LearningPersistence 来使用一个简单的测试解决方案，显然这很快就会改变！

所以我有 3 个项目：

IceDataExtractor - 发送消息的客户端

IceProcessManager - 处理消息

Messages - 包含一条消息 class Messages

我正在使用 NServiceBus.Bootstrap.WindowsService 2.0.1

生成的标准代码

Here is page I used as to get sample

然后我修改如下

Ice 数据提取器

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);
    }
}

测试消息class

using System;

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

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

我有一个消息处理程序

TestMessageHandler

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 启动和运行ning 之前，但这不是问题，因为如果我离开 ProcessManager 运行ning（即运行ning ] 来自资源管理器）然后运行提取器，没有收到消息

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

有人可以帮忙吗？

保罗

Answer 1

如果我没有遗漏某些内容，您是否为两个实例使用了相同的端点名称？

var endpointConfiguration = new EndpointConfiguration("IceDataExtractor");

当您将邮件路由到不存在的 "IceDataManager" 时。

我猜你可能贴错了代码？

NServiceBus 测试客户端不接收消息

NServiceBus test client not receiving Messages

nservicebus