0

私は以下を使用しています: 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);

これによりメッセージがキューに送信され、RabbitMq 管理ポータルでヘッダーを除くすべての詳細 (AppID、Type、Message Body など) を確認できます。

私は何が欠けていますか?それはいくつかの構成ですか、それとも何ですか?

ヘッダーの送信方法に関する基本的なチュートリアルへのリンクを教えていただければ幸いです。

ハマった。助けてください。

4

1 に答える 1