qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject svn commit: r745115 - in /qpid/trunk/qpid/cpp/src/qpid/client: SubscriptionManager.cpp SubscriptionManager.h
Date Tue, 17 Feb 2009 15:19:40 GMT
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


Mime
View raw message