summaryrefslogtreecommitdiff
path: root/cpp/examples
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/examples')
-rw-r--r--cpp/examples/messaging/drain.cpp2
-rw-r--r--cpp/examples/messaging/spout.cpp6
2 files changed, 4 insertions, 4 deletions
diff --git a/cpp/examples/messaging/drain.cpp b/cpp/examples/messaging/drain.cpp
index 05e6f23642..a2bb1c9d3a 100644
--- a/cpp/examples/messaging/drain.cpp
+++ b/cpp/examples/messaging/drain.cpp
@@ -102,7 +102,7 @@ int main(int argc, char** argv)
Duration timeout = options.getTimeout();
Message message;
while (receiver.fetch(message, timeout)) {
- std::cout << "Message(properties=" << message.getHeaders() << ", content='" ;
+ std::cout << "Message(properties=" << message.getProperties() << ", content='" ;
if (message.getContentType() == "amqp/map") {
std::cout << MapView(message);
} else {
diff --git a/cpp/examples/messaging/spout.cpp b/cpp/examples/messaging/spout.cpp
index e9a6987f5c..4b67945317 100644
--- a/cpp/examples/messaging/spout.cpp
+++ b/cpp/examples/messaging/spout.cpp
@@ -125,9 +125,9 @@ struct Options : public qpid::Options
std::string name;
std::string value;
if (nameval(property, name, value)) {
- message.getHeaders()[name] = value;
+ message.getProperties()[name] = value;
} else {
- message.getHeaders()[name] = Variant();
+ message.getProperties()[name] = Variant();
}
}
@@ -177,7 +177,7 @@ int main(int argc, char** argv)
for (uint count = 0; (count < options.count || options.count == 0) && end > now(); count++) {
if (!options.replyto.empty()) message.setReplyTo(Address(options.replyto));
std::string id = options.id.empty() ? Uuid(true).str() : options.id;
- message.getHeaders()["spout-id"] = (boost::format("%1%:%2%") % id % count).str();
+ message.getProperties()["spout-id"] = (boost::format("%1%:%2%") % id % count).str();
sender.send(message);
}
connection.close();