Report Basic.RecoverOk on connection thread

Author: Emile Joubert

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

@@ -629,6 +629,14 @@ void HandleBasicGetOk(ulong deliveryTag,
         ///</remarks>
         void HandleBasicGetEmpty();
 
+        ///<summary>Handle incoming Basic.RecoverOk methods
+        ///received in reply to Basic.Recover . All messages
+        ///received before this is invoked that haven't been
+        ///ack'ed will be redelivered. All messages received
+        ///afterwards won't be.
+        ///</summary>
+        void HandleBasicRecoverOk();
+
         [AmqpForceOneWay]
         [AmqpMethodMapping(null, "basic", "recover")]
         void _Private_BasicRecover(bool requeue);

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

@@ -798,7 +798,6 @@ public void BasicRecover(bool requeue)
             }
 
             k.GetReply();
-            OnBasicRecoverOk(new EventArgs());
         }
 
         public abstract void BasicQos(uint prefetchSize,
@@ -970,6 +969,13 @@ public void HandleBasicGetEmpty()
             k.HandleCommand(null); // release the continuation.
         }
 
+        public void HandleBasicRecoverOk()
+        {
+            SimpleBlockingRpcContinuation k = (SimpleBlockingRpcContinuation)m_continuationQueue.Next();
+            k.HandleCommand(null);
+            OnBasicRecoverOk(new EventArgs());
+        }
+
         public abstract ConnectionTuneDetails ConnectionStartOk(IDictionary clientProperties,
                                                                 string mechanism,
                                                                 byte[] response,