Author: aconway
Date: Tue Feb 17 15:19:39 2009
New Revision: 745115
URL: http://svn.apache.org/viewvc?rev=745115&view=rev
Log:
Fixed bug in setFlowControl - was recursively calling self.
Modified:
qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.cpp
qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.h
Modified: qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.cpp?rev=745115&r1=745114&r2=745115&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.cpp Tue Feb 17
15:19:39 2009
@@ -141,6 +141,14 @@
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
Modified: qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.h
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.h?rev=745115&r1=745114&r2=745115&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/SubscriptionManager.h Tue Feb 17
15:19:39 2009
@@ -218,9 +218,7 @@
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 @@
*...@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.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org
