summaryrefslogtreecommitdiff
path: root/qpid/cpp/examples/request-response/client.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-11-13 18:48:43 +0000
committerGordon Sim <gsim@apache.org>2008-11-13 18:48:43 +0000
commit74b553b6ef2ccaa18a85c729b00cd0f14233e3b1 (patch)
tree5b23d095684c1362a4c6c2148b6043472a7d2f04 /qpid/cpp/examples/request-response/client.cpp
parent84cd555a220a48737adb78154de4adbb2ac6d1e1 (diff)
downloadqpid-python-74b553b6ef2ccaa18a85c729b00cd0f14233e3b1.tar.gz
Minor cleanup edits to examples (from jrobie@redhat.com)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@713785 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/examples/request-response/client.cpp')
-rw-r--r--qpid/cpp/examples/request-response/client.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/qpid/cpp/examples/request-response/client.cpp b/qpid/cpp/examples/request-response/client.cpp
index aace2109fa..a71a6368b0 100644
--- a/qpid/cpp/examples/request-response/client.cpp
+++ b/qpid/cpp/examples/request-response/client.cpp
@@ -55,12 +55,11 @@
*
*/
-
#include <qpid/client/Connection.h>
-#include <qpid/client/SubscriptionManager.h>
#include <qpid/client/Session.h>
#include <qpid/client/Message.h>
#include <qpid/client/MessageListener.h>
+#include <qpid/client/SubscriptionManager.h>
#include <unistd.h>
#include <cstdlib>
@@ -71,6 +70,9 @@
using namespace qpid::client;
using namespace qpid::framing;
+using std::stringstream;
+using std::string;
+
class Listener : public MessageListener{
private:
SubscriptionManager& subscriptions;
@@ -94,14 +96,11 @@ void Listener::received(Message& message) {
}
-using std::stringstream;
-using std::string;
int main(int argc, char** argv) {
const char* host = argc>1 ? argv[1] : "127.0.0.1";
int port = argc>2 ? atoi(argv[2]) : 5672;
Connection connection;
- Message request;
try {
connection.open(host, port);
Session session = connection.newSession();
@@ -123,6 +122,7 @@ int main(int argc, char** argv) {
// Each client sends the name of their own response queue so
// the service knows where to route messages.
+ Message request;
request.getDeliveryProperties().setRoutingKey("request");
request.getMessageProperties().setReplyTo(ReplyTo("amq.direct", response_queue.str()));