MassTransit Consumer не вызывается

Question

В следующем примере программы (используя MassTransit, Azure ServiceBus) я могу отправлять сообщения в очередь, но моя конечная точка приема / получатель, похоже, не получает сообщение. Что я здесь не так делаю? (Простая публикация и пример обработчика, приведенные в этой ссылке (http://masstransit -project.com / MassTransit / quickstart.html ), работают отлично!)

    static async Task MainAsync(string[] args)
    {
        var bus = Bus.Factory.CreateUsingAzureServiceBus(cfg =>
        {
            var serviceUri = ServiceBusEnvironment.CreateServiceUri("sb", "{sb}", "{sb-name}");
            var host = cfg.Host(serviceUri, h =>
            {
                h.OperationTimeout = TimeSpan.FromSeconds(5);
                h.TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider(
                    "RootManageSharedAccessKey",
                    "{key}");
                h.TransportType = TransportType.NetMessaging;

            });

            cfg.ReceiveEndpoint(host, "test_queue", ep =>
            {
                ep.Consumer<SayHelloCommandConsumer>();
            });
        });


        bus.Start();

        await SendAHello(bus);

        Console.WriteLine("Press any key to exit");
        Console.ReadKey();

        bus.Stop();
    }

    private static async Task SendAHello(IBusControl bus)
    {

        var sendToUri = new Uri("queue-end-point-address");
        var endPoint = await bus.GetSendEndpoint(sendToUri);
        await endPoint.Send<ISayHello>( new
            {
                Message = "Hello there !"
            });
    }
}
public class SayHelloCommandConsumer : IConsumer<ISayHello>
{
    public Task Consume(ConsumeContext<ISayHello> context)
    {
        var command = context.Message;
        return Console.Out.WriteLineAsync($"Recieved a message {command}");
    }
}

public interface ISayHello
{
    string Message { get; set; }
}

}

Answer 1

Адрес очереди выглядел подозрительным, и, похоже, вы его исправили.