MassTransit не получает Azure ServiceBus Сообщения темы

Question

Я отслеживаю тему, а субтитры и сообщения вступают, однако мой потребитель masstransit ничего не получает.

Вот как это была установка:

var bus = Bus.Factory.CreateUsingAzureServiceBus(
         cfg => 
         { 
          var azSbHost = cfg.Host(new Uri(CloudConfigurationManager.GetSetting("ServiceBus.Url")) 
           , host => 
           { 
            host.TokenProvider = TokenProvider 
             .CreateSharedAccessSignatureTokenProvider 
             (CloudConfigurationManager.GetSetting("ServiceBus.SharedAccessKeyName"), 
              CloudConfigurationManager.GetSetting("ServiceBus.AccessKey"), 
              TokenScope.Namespace);          
           }); 

          cfg.ReceiveEndpoint(azSbHost, 
           e => 
           { 
            e.Consumer<PingConsumer>(); 
           }); 
          //azSbHost. 
         }); 

Пинг Потребитель:

public class PingConsumer : IConsumer<Ping> 
{ 
    public async Task Consume(ConsumeContext<Ping> pingContext) 
    { 
     pingContext.Respond(new Pong 
     { 
      Message = "Pong: " + pingContext.Message.Message 
     }); 
    } 
} 

И отправитель:

  var pong = await _bus.CreatePublishRequestClient<Ping, Pong>(TimeSpan.FromSeconds(10),null).Request(
      new Ping {Message = "Ping: " + message}); 

В Azure, я вижу мое сообщение кол лазания и не спускаться. Поэтому сообщения попадают в очередь, но потребитель не потребляет сообщение.

Answer 1

Мне не хватает ОЧЕНЬ важного ключевого вызова, чтобы все это работало как на стороне клиента, так и на стороне сервера.

Bus.Start