diff options
| author | Alan Conway <aconway@apache.org> | 2006-11-09 01:29:59 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2006-11-09 01:29:59 +0000 |
| commit | 0ef44feacbbdc496feac7cd76f14b101407b9134 (patch) | |
| tree | 234428c428cb0089b5c1bec5f0e06ecb0fc12cda /qpid/cpp/test/client/topic_publisher.cpp | |
| parent | 22b4cec87dfe57326523337f2233a4033f532edb (diff) | |
| download | qpid-python-0ef44feacbbdc496feac7cd76f14b101407b9134.tar.gz | |
More separation of concerns with APR, client side complete.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@472732 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/test/client/topic_publisher.cpp')
| -rw-r--r-- | qpid/cpp/test/client/topic_publisher.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/qpid/cpp/test/client/topic_publisher.cpp b/qpid/cpp/test/client/topic_publisher.cpp index 22c36ea9e3..1e1a91dfff 100644 --- a/qpid/cpp/test/client/topic_publisher.cpp +++ b/qpid/cpp/test/client/topic_publisher.cpp @@ -114,7 +114,7 @@ int main(int argc, char** argv){ if(!max || time > max) max = time; if(!min || time < min) min = time; sum += time; - std::cout << "Completed " << (i+1) << " of " << batchSize << " in " << nsecsToMsecs(time) << "ms" << std::endl; + std::cout << "Completed " << (i+1) << " of " << batchSize << " in " << time << "ms" << std::endl; } publisher.terminate(); int64_t avg = sum / batchSize; @@ -133,13 +133,12 @@ int main(int argc, char** argv){ Publisher::Publisher(Channel* _channel, const std::string& _controlTopic, bool tx) : channel(_channel), controlTopic(_controlTopic), transactional(tx){} -void Publisher::received(Message& msg){ +void Publisher::received(Message& ){ //count responses and when all are received end the current batch Monitor::ScopedLock l(monitor); if(--count == 0){ monitor.notify(); } - std::cout << "Received report: " << msg.getData() << " (" << count << " remaining)." << std::endl; } void Publisher::waitForCompletion(int msgs){ |