summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/SubscriptionManager.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-02-17 15:19:39 +0000
committerAlan Conway <aconway@apache.org>2009-02-17 15:19:39 +0000
commit65e7c659aaf36d9113956645b95e6c3674cee154 (patch)
tree513c4d76c5bfb48b6b3e20ca24d6239297b9d11f /cpp/src/qpid/client/SubscriptionManager.cpp
parentb35947d1e0f7d8dfaa1367d16395126771c5d2e2 (diff)
downloadqpid-python-65e7c659aaf36d9113956645b95e6c3674cee154.tar.gz
Fixed bug in setFlowControl - was recursively calling self.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745115 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/SubscriptionManager.cpp')
-rw-r--r--cpp/src/qpid/client/SubscriptionManager.cpp8
1 files changed, 8 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/SubscriptionManager.cpp b/cpp/src/qpid/client/SubscriptionManager.cpp
index f9d0ecbf80..1d1d23056e 100644
--- a/cpp/src/qpid/client/SubscriptionManager.cpp
+++ b/cpp/src/qpid/client/SubscriptionManager.cpp
@@ -141,6 +141,14 @@ void SubscriptionManager::registerFailoverHandler (boost::function<void ()> fh)
dispatcher.registerFailoverHandler(fh);
}
+void SubscriptionManager::setFlowControl(const std::string& name, const FlowControl& flow) {
+ getSubscription(name).setFlowControl(flow);
+}
+
+void SubscriptionManager::setFlowControl(const std::string& name, uint32_t messages, uint32_t bytes, bool window) {
+ setFlowControl(name, FlowControl(messages, bytes, window));
+}
+
}} // namespace qpid::client
#endif