RabbitMQ - SimpleAmqpClient - я пытаюсь отправить заголовки вместе с моим сообщением, но заголовки не отправляются;Что я делаю неправильно? - PullRequest
Новая
       54

RabbitMQ - SimpleAmqpClient - я пытаюсь отправить заголовки вместе с моим сообщением, но заголовки не отправляются;Что я делаю неправильно?

0 голосов
/ 08 ноября 2019

Я использую следующее: https://github.com/alanxz/SimpleAmqpClient

Я пытаюсь отправить заголовки вместе с моим сообщением, но заголовки не отправляются;что я делаю не так?

Вот как выглядит мой код. У меня есть объект конфигурации с некоторыми базовыми значениями конфигурации. 

auto channel = AmqpClient::Channel::Create("localhost", 5672, configuration.UserName, configuration.Password, configuration.VirtualHost, 131072);

channel->DeclareQueue(configuration.QueueName, false, true, false, true);
auto messageBody = "simple json string message nothing fancy"
auto message = AmqpClient::BasicMessage::Create(messageBody);
message->DeliveryMode(AmqpClient::BasicMessage::delivery_mode_t::dm_nonpersistent);
message->ContentType("application/json");
message->Type("XYZRequest");
message->AppId("a guid");
auto headerTable = message->HeaderTable();
headersTable.insert(std::pair<string, string>("Key-1", "value-1"));
headersTable.insert(std::pair<string, string>("Key-2", "value-2"));

channel->BasicPublish(std::string(), configuration.ScoreQueueName, message);

Это отправляет сообщение в очередь, и я вижу все подробности (AppID, Type, Message Body и т. Д.) На портале управления RabbitMqкроме заголовков.

Что мне не хватает? Это какая-то конфигурация или что это?

Буду признателен, если кто-нибудь даст мне ссылку на базовый учебник по отправке заголовков.

Я застрял. Пожалуйста, помогите.

1 Ответ

0 голосов
/ 09 ноября 2019

message->HeaderTable() не возвращает ссылку на заголовки, он возвращает ее копию.

Чтобы установить заголовки, сначала необходимо создать таблицу headersTable, а затем использовать message->HeadersTable(headersTable).

* 1006. *
...