summaryrefslogtreecommitdiff
path: root/cpp/examples/messaging/drain.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2013-12-20 02:01:56 +0000
committerAlan Conway <aconway@apache.org>2013-12-20 02:01:56 +0000
commit03376b220a25865653cbb59280a28213233a07f2 (patch)
tree811e08b1a08130d60dabb4524991c5fcda6ce102 /cpp/examples/messaging/drain.cpp
parentda607513077cd23764579e495851c5e0633ac10f (diff)
downloadqpid-python-03376b220a25865653cbb59280a28213233a07f2.tar.gz
NO-JIRA: Added ostream operator for qpid::Messaging::Message
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1552476 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/examples/messaging/drain.cpp')
-rw-r--r--cpp/examples/messaging/drain.cpp13
1 files changed, 2 insertions, 11 deletions
diff --git a/cpp/examples/messaging/drain.cpp b/cpp/examples/messaging/drain.cpp
index 6ac1d3a236..aa2d7b4964 100644
--- a/cpp/examples/messaging/drain.cpp
+++ b/cpp/examples/messaging/drain.cpp
@@ -21,6 +21,7 @@
#include <qpid/messaging/Connection.h>
#include <qpid/messaging/Message.h>
+#include <qpid/messaging/Message_ostream.h>
#include <qpid/messaging/Receiver.h>
#include <qpid/messaging/Session.h>
@@ -92,17 +93,7 @@ int main(int argc, char** argv)
int i = 0;
while (receiver.fetch(message, timeout)) {
- std::cout << "Message(properties=" << message.getProperties();
- if (!message.getSubject().empty()) {
- std::cout << ", subject='" << message.getSubject() << "'";
- }
- std::cout << ", content='";
- if (message.getContentType() == "amqp/map") {
- std::cout << message.getContentObject().asMap();
- } else {
- std::cout << message.getContentObject();
- }
- std::cout << "')" << std::endl;
+ std::cout << message << std::endl;
session.acknowledge();
if (count && (++i == count))
break;