diff options
author | Alan Conway <aconway@apache.org> | 2009-02-17 15:19:39 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2009-02-17 15:19:39 +0000 |
commit | 65e7c659aaf36d9113956645b95e6c3674cee154 (patch) | |
tree | 513c4d76c5bfb48b6b3e20ca24d6239297b9d11f /cpp/src/qpid/client/SubscriptionManager.cpp | |
parent | b35947d1e0f7d8dfaa1367d16395126771c5d2e2 (diff) | |
download | qpid-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.cpp | 8 |
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 |