在masstransit中，如何将当前区域性设置为正在执行的消息？

using MassTransit;

public class MyMessage
{
    public string Content { get; set; }
}

public class MyMessageConsumer : IConsumer<MyMessage>
{
    public Task Consume(ConsumeContext<MyMessage> context)
    {
        // 获取当前区域性
        var currentCulture = System.Threading.Thread.CurrentThread.CurrentCulture;

        // 执行消息处理逻辑

        return Task.CompletedTask;
    }
}

public class MessagePublisher
{
    private readonly IPublishEndpoint _publishEndpoint;

    public MessagePublisher(IPublishEndpoint publishEndpoint)
    {
        _publishEndpoint = publishEndpoint;
    }

    public async Task PublishMessage(MyMessage message)
    {
        // 设置区域性
        var headers = new Dictionary<string, object>
        {
            { "Culture", System.Threading.Thread.CurrentThread.CurrentCulture.Name }
        };

        // 发布消息
        await _publishEndpoint.Publish(message, headers);
    }
}