title: Masstransit not consuming non MassTransit messages
body: <p>I have to publish a message using Python and consume it using MassTransit (.Net core app).</p>
  <p>To test, I created a Console Application to produce the messages using the Azure.ServiceBuss library.
  The consumer is a MassTransit implementation of the ServiceBus.</p>
  <p>When I send the message to the queue (using my console application), MassTransit is not able to consume it.
  I am aware of the Interoperability and all the headers we must send in order to MassTransit consume the messages, but I am not able to make the consumer work.</p>
  <p>The producer:</p>
  <pre><code>namespace MassTransit.MultipleBus.ServiceBus.Models.Commands
  {
      class Program
      {
          const string ServiceBusConnectionString = &quot;connstring&quot;;
          const string QueueName = &quot;topic&quot;;
          static IQueueClient queueClient;
  
          public static async Task Main(string[] args)
          {
              queueClient = new QueueClient(ServiceBusConnectionString, QueueName);
  
              // Send messages.
              await SendMessagesAsync();
  
              Console.WriteLine(&quot;ENVIOU&quot;);
              Console.ReadKey();
  
              await queueClient.CloseAsync();
          }
  
          private static async Task SendMessagesAsync()
          {
              try
              {
                  while (true)
                  {
                      string messageBody = JsonConvert.SerializeObject(new EnviarExemploPocAzureServiceBusCommand(
                          NewId.NextGuid(),
                          NewId.NextGuid(),
                          new Proposta()
                          )
                      {
                          Headers = new Dictionary&lt;string, object&gt;() { },
                          Host = new HostInfo()
                      });
  
                      var message = new Message(Encoding.UTF8.GetBytes(messageBody));
  
                      Console.WriteLine($&quot;Enviando mensagem: {messageBody}&quot;);
  
                      await queueClient.SendAsync(message);
  
                      Console.WriteLine(&quot;Enviado. Enviar outro?&quot;);
                      Console.ReadKey();
                  }
              }
              catch (Exception exception)
              {
                  Console.WriteLine($&quot;{DateTime.Now} :: Exception: {exception.Message}&quot;);
              }
          }
      }
  }
  </code></pre>
  <p>The class I'm sending:</p>
  <pre><code>namespace MassTransit.MultipleBus.ServiceBus.Models.Commands
  {
      public class EnviarExemploPocAzureServiceBusCommand
      {
          public EnviarExemploPocAzureServiceBusCommand(Guid msgId, Guid convId, Proposta msg)
          {
              MessageId = msgId.ToString();
              ConversationId = convId.ToString();
              MessageType = new[]
              {
                  &quot;urn:message:MassTransit.MultipleBus.ServiceBus.Models.Commands:Proposta&quot;
              };
              Message = msg;
              SourceAddress = &quot;&quot;;
              DestinationAddress = &quot;sb://organization.servicebus.windows.net/topic&quot;;
          }
  
          public string DestinationAddress { get; set; }
  
          public string MessageId { get; set; }
  
          public string ConversationId { get; set; }
  
          public string SourceAddress { get; set; }
  
          public HostInfo Host { get; set; }
  
          public IDictionary&lt;string, object&gt; Headers { get; set; }
  
          public Proposta Message { get; set; }
  
          public string[] MessageType { get; set; }
      }
  
      public class Proposta
      {
          public Proposta()
          {
              Nome = &quot;TESTE 2&quot;;
              AcaoId = 2;
              Mensagem = &quot;TESTE 2&quot;;
          }
  
          public string Nome { get; set; }
          public int AcaoId { get; set; }
          public string Mensagem { get; set; }
      }
  
      public class HostInfo
      {
          public HostInfo()
          {
              MachineName = &quot;NOTEXXXXX&quot;;
              ProcessName = &quot;iisexpress&quot;;
              ProcessId = 34188;
              Assembly = &quot;MassTransit.MultipleBus&quot;;
              AssemblyVersion = &quot;1.0.0.0&quot;;
              FrameworkVersion = &quot;3.1.5&quot;;
              MassTransitVersion = &quot;7.0.2.0&quot;;
              OperatingSystemVersion = &quot;Microsoft Windows NT 10.0.19041.0&quot;;
          }
  
          public string MachineName { get; set; }
  
          public string ProcessName { get; set; }
  
          public int ProcessId { get; set; }
  
          public string Assembly { get; set; }
  
          public string AssemblyVersion { get; set; }
  
          public string FrameworkVersion { get; set; }
  
          public string MassTransitVersion { get; set; }
  
          public string OperatingSystemVersion { get; set; }
  
      }
  }
  </code></pre>
  <p>The message queued in ServiceBus:</p>
  <pre><code>{
      &quot;DestinationAddress&quot;: &quot;sb://organization.servicebus.windows.net/topic&quot;,
      &quot;MessageId&quot;: &quot;00010000-0faa-0009-6939-08d854e183aa&quot;,
      &quot;ConversationId&quot;: &quot;00010000-0faa-0009-69f0-08d854e183aa&quot;,
      &quot;SourceAddress&quot;: &quot;&quot;,
      &quot;Host&quot;: {
          &quot;MachineName&quot;: &quot;NOTEXXXXX&quot;,
          &quot;ProcessName&quot;: &quot;iisexpress&quot;,
          &quot;ProcessId&quot;: 32608,
          &quot;Assembly&quot;: &quot;MassTransit.MultipleBus&quot;,
          &quot;AssemblyVersion&quot;: &quot;1.0.0.0&quot;,
          &quot;FrameworkVersion&quot;: &quot;3.1.5&quot;,
          &quot;MassTransitVersion&quot;: &quot;7.0.2.0&quot;,
          &quot;OperatingSystemVersion&quot;: &quot;Microsoft Windows NT 10.0.19041.0&quot;
      },
      &quot;Headers&quot;: {
      },
      &quot;Message&quot;: {
          &quot;nome&quot;: &quot;TESTE 2&quot;,
          &quot;acaoId&quot;: 2,
          &quot;mensagem&quot;: &quot;TESTE 2&quot;
      },
      &quot;MessageType&quot;: [
          &quot;urn:message:MassTransit.MultipleBus.ServiceBus.Models.Commands:Proposta&quot;
      ]
  }
  </code></pre>
  <p>The consumer startup:</p>
  <pre><code>services.AddMassTransit&lt;IAzureServiceBusService&gt;(x =&gt;
              {
                  x.AddConsumer&lt;EnviarExemploPocAzureServiceBusCommandHandler&gt;();
  
                  x.UsingAzureServiceBus((context, cfg) =&gt;
                  {
                      cfg.UseConcurrencyLimit(serviceBusSettings.AzureServiceBusSettings.ExemploAplicacaoPocA.ConcurrencyLimit);
  
                      cfg.Host(&quot;connString&quot;, h =&gt;
                      {
                          h.OperationTimeout = TimeSpan.FromSeconds(serviceBusSettings.AzureServiceBusSettings.ExemploAplicacaoPocA.OperationTimeout);
                          h.TransportType = Microsoft.Azure.ServiceBus.TransportType.AmqpWebSockets;
                      });
  
                      cfg.UseServiceBusMessageScheduler();
                  });
              });
  
              services.AddMassTransitHostedService();
              services.AddSettings(configuration);
  </code></pre>
  <p>The handler:</p>
  <pre><code>namespace MassTransit.MultipleBus.ServiceBus.Handlers.CommandHandlers
  {
      public class EnviarExemploPocAzureServiceBusCommandHandler : IConsumer&lt;Proposta&gt;
      {
          public async Task Consume(ConsumeContext&lt;Proposta&gt; context)
          {
              await Task.CompletedTask;
          }
      }
  
      public class EnviarExemploPocAzureServiceBusFaultCommandHandler : IConsumer&lt;Fault&lt;EnviarExemploPocAzureServiceBusCommand&gt;&gt;
      {
          public async Task Consume(ConsumeContext&lt;Fault&lt;EnviarExemploPocAzureServiceBusCommand&gt;&gt; context)
          {
              await Task.CompletedTask;
          }
      }
  }
  </code></pre>
  <p>When I send the message using MassTransit as well, the consumer works and the message is queued like:</p>
  <pre><code>{
    &quot;messageId&quot;: &quot;00010000-0faa-0009-6497-08d854edbfe1&quot;,
    &quot;conversationId&quot;: &quot;00010000-0faa-0009-3b83-08d854edbfe5&quot;,
    &quot;sourceAddress&quot;: &quot;sb://organization.servicebus.windows.net/XXXX&quot;,
    &quot;destinationAddress&quot;: &quot;sb://organization.servicebus.windows.net/topic&quot;,
    &quot;messageType&quot;: [
      &quot;urn:message:MassTransit.MultipleBus.ServiceBus.Models.Commands:Proposta&quot;
    ],
    &quot;message&quot;: {
      &quot;nome&quot;: &quot;TESTE DOIS&quot;,
      &quot;acaoId&quot;: 2,
      &quot;mensagem&quot;: &quot;TESTE DOIS&quot;
    },
    &quot;sentTime&quot;: &quot;2020-09-09T18:25:37.6127127Z&quot;,
    &quot;headers&quot;: {
      &quot;MT-Activity-Id&quot;: &quot;|1e87ff49-4beb56732bfd4887.3.&quot;
    },
    &quot;host&quot;: {
      &quot;machineName&quot;: &quot;NOTEXXXXXX&quot;,
      &quot;processName&quot;: &quot;iisexpress&quot;,
      &quot;processId&quot;: 37092,
      &quot;assembly&quot;: &quot;MassTransit.MultipleBus&quot;,
      &quot;assemblyVersion&quot;: &quot;1.0.0.0&quot;,
      &quot;frameworkVersion&quot;: &quot;3.1.5&quot;,
      &quot;massTransitVersion&quot;: &quot;7.0.2.0&quot;,
      &quot;operatingSystemVersion&quot;: &quot;Microsoft Windows NT 10.0.19041.0&quot;
    }
  }
  </code></pre>
  <p>What am I doing wrong?
  The namespace seems to be correct, I did everything I found about it and I can't make it work.
  Can someone help me?</p>