You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Gordon Sim (JIRA)" <qp...@incubator.apache.org> on 2009/08/18 15:12:15 UTC
[jira] Resolved: (QPID-2053) perftest users might benefit from
having possibility to specify the queue name
[ https://issues.apache.org/jira/browse/QPID-2053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gordon Sim resolved QPID-2053.
------------------------------
Resolution: Fixed
Implemented as r805404.
> 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: M3, M4
> Environment: qpid, perftest tool
> Reporter: Frantisek Reznicek
> Priority: Trivial
> Original Estimate: 1h
> Remaining Estimate: 1h
>
> 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:dev-subscribe@qpid.apache.org