如何用RabbitMQ请求传递头

Question

我有以下代码，用于创建和I审视客户端客户端并发送请求并等待响应。在这里你可以看到，我也用GreenPipe设置了一些标头值

public async Task<CustomerData> GetCustomerData(CustomerDetailsReq request, CHeader headerKey)
{
    CustomerData rtnRes = new();

    using (var req = _clientCustomerDetailsReq.Create(request))
    {
        req.UseExecute(x => x.Headers.Set("datetime", headerKey.datetime));
        req.UseExecute(x => x.Headers.Set("languageCode", headerKey.languageCode));
        req.UseExecute(x => x.Headers.Set("version", headerKey.version));

        var response = await req.GetResponse<CustomerData>();
        rtnRes = response.Message;
    }

    return rtnRes;
}

现在，我需要我的要求是，我不需要消费者端的任何响应，只想将请求传递给带有一些标头值的消费者。为此，我只需发布命令并忘记它。我的代码如下，

IPublishEndpoint _publishEndpoint;

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

public async Task<string> TestMethod(CustomerDetailsReq request)
{
    string datas = "";
    try
    {
        await _publishEndpoint.Publish<CustomerDetailsReq>(orderRequest);
    }
    catch (Exception)
    {
        throw;
    }
    return datas;
}

但现在，我关心的是，我如何用它传递头值？

Answer 1

您可以在发布调用中指定标题:

await _publishEndpoint.Publish<CustomerDetailsReq>(orderRequest, context =>
{
    context.Headers.Set("datetime", headerKey.datetime);
    context.Headers.Set("languageCode", headerKey.languageCode);
    context.Headers.Set("version", headerKey.version);
});