Activity Creation and context propagation thru RabbitMQ headers in IBasicProperties

RabbitMessaging.cs

public async Task SendMessage(string Message, string Queue)
{
  await Task.Run(() =>
  {
    using (var activity = _activitySource.StartActivity("Queue user creation request", ActivityKind.Producer))
    {
      using (var channel = _conn.CreateModel())
      {
        channel.QueueDeclare(Queue, false, false, false, null);
        ActivityContext contextToInject = default;

        if (activity is not null)
        {
            contextToInject = activity.Context;
        }
        else if (Activity.Current is not null)
        {
            contextToInject = Activity.Current.Context;
        }

        var props = channel.CreateBasicProperties();
        var propagationContext = new PropagationContext(contextToInject, Baggage.Current);
        Propagator.Inject(propagationContext, props, InjectHeaders);                    
        channel.BasicPublish("", Queue, props, System.Text.Encoding.UTF8.GetBytes(Message));
      }
    }
  });
}