You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2010/04/12 15:21:14 UTC
svn commit: r933223 - /qpid/trunk/qpid/cpp/src/tests/qpid_cpp_benchmark
Author: aconway
Date: Mon Apr 12 13:21:14 2010
New Revision: 933223
URL: http://svn.apache.org/viewvc?rev=933223&view=rev
Log:
Added --ack-frequency to qpid_cpp_benchmark.
Modified:
qpid/trunk/qpid/cpp/src/tests/qpid_cpp_benchmark
Modified: qpid/trunk/qpid/cpp/src/tests/qpid_cpp_benchmark
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/qpid_cpp_benchmark?rev=933223&r1=933222&r2=933223&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/qpid_cpp_benchmark (original)
+++ qpid/trunk/qpid/cpp/src/tests/qpid_cpp_benchmark Mon Apr 12 13:21:14 2010
@@ -40,6 +40,8 @@ op.add_option("--send-rate", default=0,
help="send rate limited to R messages/second, 0 means no limit (default %default)")
op.add_option("--content-size", default=1024, type="int", metavar="BYTES",
help="message size in bytes (default %default)")
+op.add_option("--ack-frequency", default=0, metavar="N", type="int",
+ help="receiver ack's every N messages, 0 means unconfirmed")
def start_receive(queue, opts):
return Popen(["qpid_receive",
@@ -48,6 +50,7 @@ def start_receive(queue, opts):
"--forever",
"--print-content=no",
"--report-total",
+ "--ack-frequency", str(opts.ack_frequency),
],
stdout=PIPE, stderr=STDOUT)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org