summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/SubscriptionManager.cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2007-11-21 22:08:13 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2007-11-21 22:08:13 +0000
commit286ecd708ec48dc5622912bf43240e2660fadf2c (patch)
treea41db11c7693ba086ac6086ac03495fd77aa928a /cpp/src/qpid/client/SubscriptionManager.cpp
parent29f4c5f9dd9eea9a5cba07e6a06e724fa5669436 (diff)
downloadqpid-python-286ecd708ec48dc5622912bf43240e2660fadf2c.tar.gz
- added confirm mode to perftest
- added acquire mode to perftest git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@597228 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/SubscriptionManager.cpp')
-rw-r--r--cpp/src/qpid/client/SubscriptionManager.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/cpp/src/qpid/client/SubscriptionManager.cpp b/cpp/src/qpid/client/SubscriptionManager.cpp
index 1282a1cf61..c482c824f7 100644
--- a/cpp/src/qpid/client/SubscriptionManager.cpp
+++ b/cpp/src/qpid/client/SubscriptionManager.cpp
@@ -35,14 +35,14 @@ namespace client {
SubscriptionManager::SubscriptionManager(Session_0_10& s)
: dispatcher(s), session(s),
messages(UNLIMITED), bytes(UNLIMITED), window(true),
- confirmMode(true)
+ confirmMode(true), acquireMode(true)
{}
void SubscriptionManager::subscribeInternal(
const std::string& q, const std::string& dest)
{
session.messageSubscribe(arg::queue=q, arg::destination=dest,
- arg::confirmMode=confirmMode);
+ arg::confirmMode=confirmMode, arg::acquireMode=acquireMode);
setFlowControl(dest, messages, bytes, window);
}
@@ -82,6 +82,8 @@ void SubscriptionManager::setFlowControl(
void SubscriptionManager::setConfirmMode(bool c) { confirmMode=c; }
+void SubscriptionManager::setAcquireMode(bool a) { acquireMode=a; }
+
void SubscriptionManager::setAckPolicy(const AckPolicy& a) { autoAck=a; }
void SubscriptionManager::cancel(const std::string dest)