More tests

Author: michaelklishin

projects/client/Unit/src/unit/TestConnectionRecovery.cs

@@ -641,6 +641,16 @@ public override void PostHandleDelivery(ulong deliveryTag)
             }
         }
 
+        public class RejectingBasicConsumer : TestBasicConsumer1
+        {
+            public RejectingBasicConsumer(IModel model, AutoResetEvent latch, Action fn) : base(model, latch, fn) {}
+
+            public override void PostHandleDelivery(ulong deliveryTag)
+            {
+                base.m_model.BasicReject(deliveryTag, false);
+            }
+        }
+
         [Test]
         public void TestBasicAckAfterChannelRecovery()
         {
@@ -663,6 +673,17 @@ public void TestBasicNackAfterChannelRecovery()
             TestDelayedBasicAckNackAfterChannelRecovery(cons, latch);
         }
 
+        [Test]
+        public void TestBasicRejectAfterChannelRecovery()
+        {
+            var latch = new AutoResetEvent(false);
+            var cons  = new RejectingBasicConsumer(Model, latch, () => {
+                CloseAndWaitForRecovery();
+            });
+
+            TestDelayedBasicAckNackAfterChannelRecovery(cons, latch);
+        }
+
         protected void TestDelayedBasicAckNackAfterChannelRecovery(TestBasicConsumer1 cons, AutoResetEvent latch)
         {
             var q = Model.QueueDeclare(GenerateQueueName(), false, false, false, null).QueueName;