summaryrefslogtreecommitdiff
path: root/qpid/cpp/examples/messaging/queue_sender.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/examples/messaging/queue_sender.cpp')
-rw-r--r--qpid/cpp/examples/messaging/queue_sender.cpp15
1 files changed, 5 insertions, 10 deletions
diff --git a/qpid/cpp/examples/messaging/queue_sender.cpp b/qpid/cpp/examples/messaging/queue_sender.cpp
index 637e7eb8e4..1396e26d5c 100644
--- a/qpid/cpp/examples/messaging/queue_sender.cpp
+++ b/qpid/cpp/examples/messaging/queue_sender.cpp
@@ -26,14 +26,10 @@
#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";
int count = argc>2 ? atoi(argv[2]) : 10;
@@ -45,14 +41,13 @@ int main(int argc, char** argv) {
// Now send some messages ...
for (int i=0; i<count; i++) {
- Message message;
- message.getContent() << "Message " << i;
- sender.send(message);
+ std::stringstream content;
+ content << "Message " << i;
+ sender.send(Message(content.str()));
}
- // And send a final message to indicate termination.
- Message message("That's all, folks!");
- sender.send(message);
+ // And send a final message to indicate termination.
+ sender.send(Message("That's all, folks!"));
session.sync();
connection.close();
return 0;