perftest users might benefit from having possibility to specify the queue name
------------------------------------------------------------------------------
Key: QPID-2053
URL: https://issues.apache.org/jira/browse/QPID-2053
Project: Qpid
Issue Type: Improvement
Components: Tools
Affects Versions: M4, M3
Environment: qpid, perftest tool
Reporter: Frantisek Reznicek
Priority: Trivial
Current version of perftest does not allow queue name specification. It would
be beneficial to have this possibility, especially for testing purposes.
This patch works well for me (qpid project checkout rev 787816
qpid/cpp/src/tests/perftest.cpp)
*** qpid_cpp_tests/perftest.cpp 2009-06-11 11:52:26.000000000 +0200
--- qpid_cpp_tests/perftest.cpp.new 2009-06-01 11:36:14.000000000 +0200
***************
*** 74,79 ****
--- 74,80 ----
// Queue policy
uint32_t queueMaxCount;
uint64_t queueMaxSize;
+ string queueName;
bool queueDurable;
// Publisher
***************
*** 110,115 ****
--- 111,117 ----
pubs(1), count(500000), size(1024), confirm(true), durable(false),
uniqueData(false), syncPub(false),
subs(1), ack(0),
qt(1),singleConnect(false), iterations(1), mode(SHARED),
summary(false),
+ queueName("perftest"),
intervalSub(0), intervalPub(0), tx(0), txPub(0), txSub(0),
commitAsync(false)
{
addOptions()
***************
*** 141,146 ****
--- 143,149 ----
("iterations", optValue(iterations, "N"), "Desired number of
iterations of the test.")
("summary,s", optValue(summary), "Summary output: pubs/sec
subs/sec transfers/sec Mbytes/sec")
+ ("queue-name", optValue(queueName, "QUEUE-NAME"), "queue name
used by perftest program")
("queue-max-count", optValue(queueMaxCount, "N"), "queue policy:
count to trigger 'flow to disk'")
("queue-max-size", optValue(queueMaxSize, "N"), "queue policy:
accumulated size to trigger 'flow to disk'")
("queue-durable", optValue(queueDurable, "N"), "Make queue
durable (implied if durable set)")
***************
*** 267,273 ****
settings.setInt("qpid.max_size", opts.queueMaxSize);
for (size_t i = 0; i < opts.qt; ++i) {
ostringstream qname;
! qname << "perftest" << i;
queueInit(qname.str(), opts.durable || opts.queueDurable,
settings);
}
}
--- 270,277 ----
settings.setInt("qpid.max_size", opts.queueMaxSize);
for (size_t i = 0; i < opts.qt; ++i) {
ostringstream qname;
! //qname << "perftest" << i;
! qname << opts.queueName << i;
queueInit(qname.str(), opts.durable || opts.queueDurable,
settings);
}
}
***************
*** 679,685 ****
// Start pubs/subs for each queue/topic.
for (size_t i = 0; i < opts.qt; ++i) {
ostringstream key;
! key << "perftest" << i; // Queue or topic name.
if (opts.publish) {
size_t n = singleProcess ? opts.pubs : 1;
for (size_t j = 0; j < n; ++j) {
--- 683,690 ----
// Start pubs/subs for each queue/topic.
for (size_t i = 0; i < opts.qt; ++i) {
ostringstream key;
! //key << "perftest" << i; // Queue or topic name.
! key << opts.queueName << i; // Queue or topic name.
if (opts.publish) {
size_t n = singleProcess ? opts.pubs : 1;
for (size_t j = 0; j < n; ++j) {
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
