diff options
| author | Alan Conway <aconway@apache.org> | 2010-04-12 17:49:57 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2010-04-12 17:49:57 +0000 |
| commit | b83b9bd7f7faf690d31dcc73c5ec099a933c2d42 (patch) | |
| tree | ca5218d5f55e64402798b1b634efccaaae8304fc /qpid/cpp/src/tests/qpid_receive.cpp | |
| parent | 77b744ca228a8f0724e99817fd4bcc6f4c31cdfa (diff) | |
| download | qpid-python-b83b9bd7f7faf690d31dcc73c5ec099a933c2d42.tar.gz | |
qpid_cpp_benchmark waits for receivers to be ready before starting senders.
This avoids exaggerated latency numbers due to messages siting on the
queue while receivers are connecting and subscribing.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@933333 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/qpid_receive.cpp')
| -rw-r--r-- | qpid/cpp/src/tests/qpid_receive.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/qpid_receive.cpp b/qpid/cpp/src/tests/qpid_receive.cpp index 902e855c2b..d67232ad86 100644 --- a/qpid/cpp/src/tests/qpid_receive.cpp +++ b/qpid/cpp/src/tests/qpid_receive.cpp @@ -22,6 +22,7 @@ #include <qpid/messaging/Address.h> #include <qpid/messaging/Connection.h> #include <qpid/messaging/Receiver.h> +#include <qpid/messaging/Sender.h> #include <qpid/messaging/Session.h> #include <qpid/messaging/Message.h> #include <qpid/Options.h> @@ -63,6 +64,7 @@ struct Options : public qpid::Options qpid::log::Options log; bool reportTotal; uint reportEvery; + string readyAddress; Options(const std::string& argv0=std::string()) : qpid::Options("Options"), @@ -100,6 +102,8 @@ struct Options : public qpid::Options ("failover-updates", qpid::optValue(failoverUpdates), "Listen for membership updates distributed via amq.failover") ("report-total", qpid::optValue(reportTotal), "Report total throughput and latency statistics") ("report-every", qpid::optValue(reportEvery,"N"), "Report throughput and latency statistics every N messages.") + ("ready-address", qpid::optValue(readyAddress, "ADDRESS"), + "send a message to this address when ready to receive") ("help", qpid::optValue(help), "print this usage statement"); add(log); } @@ -173,6 +177,8 @@ int main(int argc, char ** argv) Duration timeout = opts.getTimeout(); bool done = false; Reporter<ThroughputAndLatency> reporter(std::cout, opts.reportEvery); + if (!opts.readyAddress.empty()) + session.createSender(opts.readyAddress).send(msg); while (!done && receiver.fetch(msg, timeout)) { reporter.message(msg); if (!opts.ignoreDuplicates || !sequenceTracker.isDuplicate(msg)) { |