Author: cctrieloff
Date: Thu Jul 16 02:16:04 2009
New Revision: 794495
URL: http://svn.apache.org/viewvc?rev=794495&view=rev
Log:
better help text, kill not so usefull option
Modified:
qpid/trunk/qpid/cpp/src/tests/latencytest.cpp
Modified: qpid/trunk/qpid/cpp/src/tests/latencytest.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/latencytest.cpp?rev=794495&r1=794494&r2=794495&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/latencytest.cpp (original)
+++ qpid/trunk/qpid/cpp/src/tests/latencytest.cpp Thu Jul 16 02:16:04 2009
@@ -57,18 +57,18 @@
bool durable;
string base;
bool singleConnect;
- uint queues;
Args() : size(256), count(1000), rate(0), reportFrequency(1000),
timeLimit(0), concurrentConnections(1),
prefetch(100), ack(0),
- durable(false), base("latency-test"), singleConnect(false),
queues(1)
+ durable(false), base("latency-test"), singleConnect(false)
{
addOptions()
("size", optValue(size, "N"), "message size")
- ("concurrentTests", optValue(concurrentConnections, "N"), "number
of concurrent test setup")
+ ("concurrentTests", optValue(concurrentConnections, "N"), "number
of concurrent test setups, will create another publisher,\
+ subcriber, queue, and connections")
("single-connection", optValue(singleConnect, "yes|no"), "Use one
connection for multiple sessions.")
("count", optValue(count, "N"), "number of messages to send")
("rate", optValue(rate, "N"), "target message rate (causes count
to be ignored)")
@@ -82,8 +82,7 @@
("durable", optValue(durable, "yes|no"), "use durable messages")
("csv", optValue(csv), "print stats in csv format
(rate,min,max,avg)")
("cumulative", optValue(cumulative), "cumulative stats in csv
format")
- ("queue-base-name", optValue(base, "<name>"), "base name for
queues")
- ("queues", optValue(queues, "N"), "declare N queues & bindings to
test routing");
+ ("queue-base-name", optValue(base, "<name>"), "base name for
queues");
}
};
@@ -419,26 +418,6 @@
Connection localConnection;
AsyncSession session;
- if (opts.queues > 1){
- opts.open(localConnection);
- session = localConnection.newSession();
- std::cout << "More than one queue being used, creating..." <<
std::endl;
- // use default binding
- for (uint i=0;i<opts.queues;i++){
-
- std::ostringstream out;
- out << opts.base << "-" << (i+1);
- session.queueDeclare(arg::queue=out.str(),
arg::durable=opts.durable, arg::autoDelete=true);
- uint msgCount =
session.queueQuery(arg::queue=out.str()).get().getMessageCount();
- if (msgCount) {
- std::cout << "Warning: found " << msgCount << " msgs on "
<< out.str() << ". Purging..." << std::endl;
- session.queuePurge(arg::queue=out.str());
- }
-
- }
- session.sync();
- std::cout << "Complete..." << std::endl;
- }
boost::ptr_vector<Test> tests(opts.concurrentConnections);
for (uint i = 0; i < opts.concurrentConnections; i++) {
@@ -463,11 +442,6 @@
}
}
- if (opts.queues > 1){
- session.close();
- localConnection.close();
- }
-
return 0;
} catch(const std::exception& e) {
std::cout << e.what() << std::endl;
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org
