You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2009/02/17 16:19:40 UTC
svn commit: r745115 - in /qpid/trunk/qpid/cpp/src/qpid/client:
SubscriptionManager.cpp SubscriptionManager.h
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-subscribe@qpid.apache.org