summaryrefslogtreecommitdiff
path: root/cpp/examples/messaging/spout.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-03-31 16:17:17 +0000
committerGordon Sim <gsim@apache.org>2010-03-31 16:17:17 +0000
commitf6f1900eb98cc1773a88a3ec309afa646438a384 (patch)
tree68e50e7aa1819afd283d73700965b539355a779d /cpp/examples/messaging/spout.cpp
parent887281838e4bf7825189ce3b0a8d7509789e6a08 (diff)
downloadqpid-python-f6f1900eb98cc1773a88a3ec309afa646438a384.tar.gz
QPID-664: made changes suggested by Alan Conway, also moved 0-10 map/list codecs to common lib
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@929606 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/examples/messaging/spout.cpp')
-rw-r--r--cpp/examples/messaging/spout.cpp11
1 files changed, 5 insertions, 6 deletions
diff --git a/cpp/examples/messaging/spout.cpp b/cpp/examples/messaging/spout.cpp
index 4b67945317..61b3f88711 100644
--- a/cpp/examples/messaging/spout.cpp
+++ b/cpp/examples/messaging/spout.cpp
@@ -21,7 +21,6 @@
#include <qpid/messaging/Address.h>
#include <qpid/messaging/Connection.h>
-#include <qpid/messaging/MapContent.h>
#include <qpid/messaging/Message.h>
#include <qpid/messaging/Sender.h>
#include <qpid/messaging/Session.h>
@@ -138,7 +137,7 @@ struct Options : public qpid::Options
}
}
- void setEntries(MapContent& content) const
+ void setEntries(Variant::Map& content) const
{
for (string_vector::const_iterator i = entries.begin(); i != entries.end(); ++i) {
std::string name;
@@ -160,18 +159,18 @@ int main(int argc, char** argv)
Connection connection(options.connectionOptions);
try {
connection.open(options.url);
- Session session = connection.newSession();
+ Session session = connection.createSession();
Sender sender = session.createSender(options.address);
Message message;
options.setProperties(message);
if (options.entries.size()) {
- MapContent content(message);
+ Variant::Map content;
options.setEntries(content);
- content.encode();
+ encode(content, message);
} else if (options.content.size()) {
message.setContent(options.content);
- message.setContentType("text/plain; charset=utf8");
+ message.setContentType("text/plain");
}
AbsTime end(now(), options.timeout);
for (uint count = 0; (count < options.count || options.count == 0) && end > now(); count++) {