- added confirm mode to perftest

- added acquire mode to perftest



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@597228 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 10 insertions, 3 deletions

diff --git a/qpid/cpp/src/tests/perftest.cpp b/qpid/cpp/src/tests/perftest.cpp
index 019b1e1fce..c7e3940086 100644
--- a/qpid/cpp/src/tests/perftest.cpp
+++ b/qpid/cpp/src/tests/perftest.cpp
@@ -48,12 +48,14 @@ struct Opts : public TestOptions {
     std::string mode;
     size_t autoAck;
     bool summary;
+	bool confirmMode;
+	bool acquireMode;
     
     Opts() :
         listen(false), publish(false), purge(false),
         count(500000), size(64), consumers(1),
         mode("shared"), autoAck(100),
-        summary(false)
+        summary(false), confirmMode(false), acquireMode(true)
     {
         addOptions() 
             ("listen", optValue(listen), "Consume messages.")
@@ -65,7 +67,9 @@ struct Opts : public TestOptions {
             ("consumers", optValue(consumers, "N"), "Number of consumers.")
             ("mode", optValue(mode, "shared|fanout|topic"), "consume mode")
             ("auto-ack", optValue(autoAck, "N"), "ack every N messages.")
-            ("summary,s", optValue(summary), "summary output only");
+            ("summary,s", optValue(summary), "summary output only")
+            ("confirm-mode", optValue(confirmMode, "N"), "confirm mode")
+            ("acquire-mode", optValue(acquireMode, "Y"), "acquire mode");
     }
 };
 
@@ -175,7 +179,8 @@ void PublishThread::run() {
             char* data = const_cast<char*>(msg.getData().data());
             *reinterpret_cast<uint32_t*>(data) = i;
             session.messageTransfer(arg::destination=exchange(),
-                                    arg::content=msg);
+                                    arg::content=msg, arg::confirmMode=opts.confirmMode,
+									arg::acquireMode=opts.acquireMode);
             if (!opts.summary && (i%10000)==0){
                  cout << "." << flush;
                  session.execution().sendSyncRequest();
@@ -267,6 +272,8 @@ void ListenThread::run() {
 
         SubscriptionManager subs(session);
         LocalQueue consume(AckPolicy(opts.autoAck));
+		subs.setConfirmMode(opts.confirmMode);
+		subs.setAcquireMode(opts.acquireMode);
         subs.subscribe(consume, consumeQueue);
         int consumed=0;
         AbsTime start=now();