Background process consuming messages and adding spans to trace

Worker.cs

private static readonly ActivitySource ActivitySource = new ActivitySource("Worker");
private static readonly TextMapPropagator Propagator = new TraceContextPropagator();

const string ACTIVITY_NAME = "Launching handler to process request";

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    stoppingToken.ThrowIfCancellationRequested();                       
    _model.QueueDeclare(_queueName, false, false, false, null);
    var consumer = new EventingBasicConsumer(_model);
    consumer.Received += async (sender, e) =>
    {
        var parentContext = Propagator.Extract(default, e.BasicProperties, ExtractHeaders);
        Baggage.Current = parentContext.Baggage;
        using (var activity = ActivitySource.StartActivity(ACTIVITY_NAME, ActivityKind.Consumer, parentContext.ActivityContext))
        {
            var payload = JsonSerializer.Deserialize<Person>(Encoding.UTF8.GetString(e.Body.Span.ToArray()));
            if (payload is not null)
            {
                await _mediator.Send(new CreatePersonAsyncCommand(payload.FirstName, payload.LastName, payload.Email));
            }
        }
        _model.BasicAck(e.DeliveryTag, false);
    };
    _model.BasicConsume(_queueName, false, consumer);
    await Task.CompletedTask;
}