summaryrefslogtreecommitdiff
path: root/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
commit7fbb0e83cc1a44b14211dcd4e42d3ebdeba2f64e (patch)
treef093090ab9827b853e323ef441135370d145ee0a /cpp/examples/request-response/client.cpp
parenta9a2e91cdba870df5ae91e8f9c6734a947a97841 (diff)
downloadqpid-python-7fbb0e83cc1a44b14211dcd4e42d3ebdeba2f64e.tar.gz
Minor cleanup edits to examples (from jrobie@redhat.com)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713785 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/examples/request-response/client.cpp')
-rw-r--r--cpp/examples/request-response/client.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/cpp/examples/request-response/client.cpp b/cpp/examples/request-response/client.cpp
index aace2109fa..a71a6368b0 100644
--- a/cpp/examples/request-response/client.cpp
+++ b/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()));