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 | cf68f76489b4def2742583fe32dc2eb998fc959c (patch) | |
| tree | 71dd4b9ce528a29498ad6f05d2a8f39a8232e65d | |
| parent | 0d99557c6c81d44c7795a0f5110a2e1afef54c28 (diff) | |
| download | qpid-python-cf68f76489b4def2742583fe32dc2eb998fc959c.tar.gz | |
Fixed bug in setFlowControl - was recursively calling self.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@745115 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/cpp/src/qpid/client/SubscriptionManager.cpp | 8 | ||||
| -rw-r--r-- | qpid/cpp/src/qpid/client/SubscriptionManager.h | 8 |
2 files changed, 10 insertions, 6 deletions
diff --git a/qpid/cpp/src/qpid/client/SubscriptionManager.cpp b/qpid/cpp/src/qpid/client/SubscriptionManager.cpp index f9d0ecbf80..1d1d23056e 100644 --- a/qpid/cpp/src/qpid/client/SubscriptionManager.cpp +++ b/qpid/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 diff --git a/qpid/cpp/src/qpid/client/SubscriptionManager.h b/qpid/cpp/src/qpid/client/SubscriptionManager.h index 1017480257..89823a11bc 100644 --- a/qpid/cpp/src/qpid/client/SubscriptionManager.h +++ b/qpid/cpp/src/qpid/client/SubscriptionManager.h @@ -218,9 +218,7 @@ class SubscriptionManager : public sys::Runnable static const uint32_t UNLIMITED=0xFFFFFFFF; /** Set the flow control for a subscription. */ - void setFlowControl(const std::string& name, const FlowControl& flow) { - getSubscription(name).setFlowControl(flow); - } + void setFlowControl(const std::string& name, const FlowControl& flow); /** Set the flow control for a subscription. *@param name: name of the subscription. @@ -228,9 +226,7 @@ class SubscriptionManager : public sys::Runnable *@param bytes: byte credit. *@param window: if true use window-based flow control. */ - void setFlowControl(const std::string& name, uint32_t messages, uint32_t bytes, bool window=true) { - setFlowControl(name, messages, bytes, window); - } + void setFlowControl(const std::string& name, uint32_t messages, uint32_t bytes, bool window=true); /** Set the default settings for subscribe() calls that don't * include a SubscriptionSettings parameter. |