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 | 295145d247a7523affdf43f8d870912b1a303caf (patch) | |
| tree | e27b156b80f0904530d512177e35284def40ab27 /cpp/test | |
| parent | f6113838a8e6d271e46466fe74884c5bf9706ae0 (diff) | |
| download | qpid-python-295145d247a7523affdf43f8d870912b1a303caf.tar.gz | |
More separation of concerns with APR, client side complete.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472732 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/test')
| -rw-r--r-- | cpp/test/client/topic_publisher.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/cpp/test/client/topic_publisher.cpp b/cpp/test/client/topic_publisher.cpp index 22c36ea9e3..1e1a91dfff 100644 --- a/cpp/test/client/topic_publisher.cpp +++ b/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){ |