From e512cef4ddb7e2e73bff17fe87915ce79f7da72d Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 2 Aug 2007 18:09:48 +0000 Subject: Some restructuring of the client code: * Introduced three separate 'handlers' for the connection, channel and execution 'layers'. * Support for asynchronous retrieval of response or completion status. * Channel methods no longer included in execution layers command id count. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@562212 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/client_test.cpp | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) (limited to 'qpid/cpp/src/tests/client_test.cpp') diff --git a/qpid/cpp/src/tests/client_test.cpp b/qpid/cpp/src/tests/client_test.cpp index cefc4338eb..4903312cd7 100644 --- a/qpid/cpp/src/tests/client_test.cpp +++ b/qpid/cpp/src/tests/client_test.cpp @@ -41,7 +41,6 @@ using namespace qpid::client; using namespace qpid::sys; using std::string; -bool verbose = false; /** * A simple message listener implementation that prints out the @@ -50,9 +49,10 @@ bool verbose = false; */ class SimpleListener : public virtual MessageListener{ Monitor* monitor; + bool verbose; public: - inline SimpleListener(Monitor* _monitor) : monitor(_monitor){} + inline SimpleListener(Monitor* _monitor, bool debug) : monitor(_monitor), verbose(debug) {} inline virtual void received(Message& msg){ if (verbose) @@ -101,7 +101,7 @@ int main(int argc, char** argv) //montior to use to notify the main thread when that message //is received. Monitor monitor; - SimpleListener listener(&monitor); + SimpleListener listener(&monitor, opts.trace); string tag("MyTag"); channel.consume(queue, tag, &listener); if (opts.trace) std::cout << "Registered consumer." << std::endl; @@ -118,11 +118,6 @@ int main(int argc, char** argv) msg.setData(data); channel.publish(msg, exchange, "MyTopic"); if (opts.trace) std::cout << "Published message: " << data << std::endl; - if (opts.trace) { - std::cout << "Publication " - << (channel.synchWithServer(qpid::sys::TIME_SEC * 1) ? " DID " : " did NOT ") - << "complete" << std::endl; - } { Monitor::ScopedLock l(monitor); -- cgit v1.2.1