diff options
author | Carl C. Trieloff <cctrieloff@apache.org> | 2007-11-21 22:08:13 +0000 |
---|---|---|
committer | Carl C. Trieloff <cctrieloff@apache.org> | 2007-11-21 22:08:13 +0000 |
commit | 286ecd708ec48dc5622912bf43240e2660fadf2c (patch) | |
tree | a41db11c7693ba086ac6086ac03495fd77aa928a /cpp/src/qpid/client/SubscriptionManager.cpp | |
parent | 29f4c5f9dd9eea9a5cba07e6a06e724fa5669436 (diff) | |
download | qpid-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.cpp | 6 |
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) |