One more test

Author: michaelklishin

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

@@ -208,6 +208,33 @@ public void TestBasicAckEventHandlerRecovery()
             Wait(latch);
         }
 
+        [Test]
+        public void TestRecoveryWithTopologyDisabled()
+        {
+            AutorecoveringConnection conn = CreateAutorecoveringConnectionWithTopologyRecoveryDisabled();
+            IModel ch = conn.CreateModel();
+            string s  = "dotnet-client.test.recovery.q2";
+            ch.QueueDelete(s);
+            ch.QueueDeclare(s, false, true, false, null);
+            ch.QueueDeclarePassive(s);
+            Assert.IsTrue(ch.IsOpen);
+
+            try
+            {
+                CloseAndWaitForRecovery(conn);
+                Assert.IsTrue(ch.IsOpen);
+                ch.QueueDeclarePassive(s);
+                Assert.Fail("Expected an exception");
+            } catch(OperationInterruptedException e)
+            {
+                // expected
+            } finally
+            {
+                conn.Abort();
+            }
+        }
+
+
         [Test]
         public void TestExchangeRecovery()
         {
@@ -518,7 +545,6 @@ public void TestConsumerRecoveryWithManyConsumers()
         }
 
         [Test]
-        [Category("Focus")]
         public void TestConsumerRecoveryOnClientNamedQueueWithOneRecovery()
         {
             var c    = CreateAutorecoveringConnection();
@@ -826,5 +852,14 @@ protected AutorecoveringConnection CreateAutorecoveringConnection()
             cf.NetworkRecoveryInterval  = RECOVERY_INTERVAL;
             return (AutorecoveringConnection)cf.CreateConnection();
         }
+
+       protected AutorecoveringConnection CreateAutorecoveringConnectionWithTopologyRecoveryDisabled()
+        {
+            var cf = new ConnectionFactory();
+            cf.AutomaticRecoveryEnabled = true;
+            cf.TopologyRecoveryEnabled  = false;
+            cf.NetworkRecoveryInterval  = RECOVERY_INTERVAL;
+            return (AutorecoveringConnection)cf.CreateConnection();
+        }
     }
 }