summaryrefslogtreecommitdiff
path: root/cpp/examples/messaging/queue_receiver.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/examples/messaging/queue_receiver.cpp')
-rw-r--r--cpp/examples/messaging/queue_receiver.cpp8
1 files changed, 1 insertions, 7 deletions
diff --git a/cpp/examples/messaging/queue_receiver.cpp b/cpp/examples/messaging/queue_receiver.cpp
index 83a44b2ca9..40f863eb30 100644
--- a/cpp/examples/messaging/queue_receiver.cpp
+++ b/cpp/examples/messaging/queue_receiver.cpp
@@ -24,16 +24,10 @@
#include <qpid/messaging/Receiver.h>
#include <qpid/messaging/Session.h>
-#include <cstdlib>
#include <iostream>
-#include <sstream>
-
using namespace qpid::messaging;
-using std::stringstream;
-using std::string;
-
int main(int argc, char** argv) {
const char* url = argc>1 ? argv[1] : "amqp:tcp:127.0.0.1:5672";
@@ -47,7 +41,7 @@ int main(int argc, char** argv) {
Message message = receiver.fetch();
std::cout << "Message: " << message.getContent() << std::endl;
session.acknowledge();
- if (message.getContent().asString() == "That's all, folks!") {
+ if (message.getContent() == "That's all, folks!") {
std::cout << "Cancelling receiver" << std::endl;
receiver.cancel();
break;