bug22974 (channel flow polarity) merged into default.

Author: Marek Majkowski

projects/client/RabbitMQ.Client/src/client/api/IModel.cs

@@ -636,7 +636,7 @@ void HandleBasicReturn(ushort replyCode,
         ///<summary>Used to send a Channel.FlowOk. Confirms that
         ///Channel.Flow from the broker was processed.</summary>
         [AmqpMethodMapping(null, "channel", "flow-ok")]
-        void _Private_ChannelFlowOk();
+        void _Private_ChannelFlowOk(bool active);
 
         ///<summary>Handle incoming Channel.Flow methods. Either
         ///stops or resumes sending the methods that have content.</summary>

projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs

@@ -146,8 +146,8 @@ public event CallbackExceptionEventHandler CallbackException
                     m_callbackException -= value;
                 }
             }
-        }
-
+        }
+
         public IBasicConsumer DefaultConsumer { get; set; }
 
         public ISession m_session;
@@ -402,15 +402,15 @@ public void HandleBasicReturn(ushort replyCode,
             OnBasicReturn(e);
         }
 
-        public abstract void _Private_ChannelFlowOk();
+        public abstract void _Private_ChannelFlowOk(bool active);
 
         public void HandleChannelFlow(bool active)
         {
             if (active)
                 m_flowControlBlock.Set();
             else
                 m_flowControlBlock.Reset();
-            _Private_ChannelFlowOk();
+            _Private_ChannelFlowOk(active);
         }
 
         public void HandleConnectionStart(byte versionMajor,