* Re-enable ConnectionRecoveryTests one at a time.

Author: lukebakken

Tests/ConnectionRecoveryTests.cs

@@ -1,4 +1,3 @@
-#if FOOBAR
 // This source code is dual-licensed under the Apache License, version
 // 2.0, and the Mozilla Public License, version 2.0.
 // Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
@@ -54,7 +53,7 @@ public class ConnectionRecoveryTests(ITestOutputHelper testOutputHelper)
     /// The error _must_ be null when the connection is closed normally even the recovery is activated. 
     /// </summary>
     /// <param name="activeRecovery"> If the recovery is enabled.</param>
-    [Theory]
+    [SkippableTheory]
     [InlineData(true)]
     [InlineData(false)]
     public async Task NormalCloseTheStatusShouldBeCorrectAndErrorNull(bool activeRecovery)
@@ -104,11 +103,12 @@ public async Task NormalCloseTheStatusShouldBeCorrectAndErrorNull(bool activeRec
     /// then the connection is closed normally. so the status should be:
     ///  - From Open to Closed
     /// </summary>
-    [Fact]
+    [SkippableFact]
     public async Task UnexpectedCloseTheStatusShouldBeCorrectAndErrorNotNull()
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         IConnection connection = await AmqpConnection.CreateAsync(
             ConnectionSettingBuilder.Create().ContainerId(_containerId).RecoveryConfiguration(
@@ -177,11 +177,12 @@ public async Task UnexpectedCloseTheStatusShouldBeCorrectAndErrorNotNull()
     /// By default, the backoff is active it will be disabled after some failed attempts.
     /// See the BackOffDelayPolicy class for more details.
     /// </summary>
-    [Fact]
+    [SkippableFact]
     public async Task OverrideTheBackOffWithBackOffDisabled()
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         IConnection connection = await AmqpConnection.CreateAsync(
             ConnectionSettingBuilder.Create().ContainerId(_containerId).RecoveryConfiguration(
@@ -240,11 +241,12 @@ public async Task OverrideTheBackOffWithBackOffDisabled()
     /// When the topology-recover is Enabled the temp queues should be recovered.
     /// the Queue is a temp queue with the Auto-Delete and Exclusive flag set to true. 
     /// </summary>
-    [Fact]
+    [SkippableFact]
     public async Task RecoveryTopologyShouldRecoverTheTempQueues()
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         string queueName = $"temp-queue-should-recover-{true}";
         IConnection connection = await AmqpConnection.CreateAsync(
@@ -288,11 +290,12 @@ public async Task RecoveryTopologyShouldRecoverTheTempQueues()
     /// When the topology-recover is  Disabled the temp queues should not be recovered.
     /// the Queue is a temp queue with the Auto-Delete and Exclusive flag set to true. 
     /// </summary>
-    [Fact]
+    [SkippableFact]
     public async Task RecoveryTopologyShouldNotRecoverTheTempQueues()
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         string queueName = $"temp-queue-should-recover-{false}";
         IConnection connection = await AmqpConnection.CreateAsync(
@@ -325,13 +328,14 @@ public async Task RecoveryTopologyShouldNotRecoverTheTempQueues()
         Assert.Equal(0, topologyListener.QueueCount());
     }
 
-    [Theory]
+    [SkippableTheory]
     [InlineData(true)]
     [InlineData(false)]
     public async Task RecoveryTopologyShouldRecoverExchanges(bool topologyEnabled)
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         const string exchangeName = "exchange-should-recover";
         IConnection connection = await AmqpConnection.CreateAsync(
@@ -384,13 +388,14 @@ public async Task RecoveryTopologyShouldRecoverExchanges(bool topologyEnabled)
         connection.Dispose();
     }
 
-    [Theory]
+    [SkippableTheory]
     [InlineData(true)]
     [InlineData(false)]
     public async Task RecoveryTopologyShouldRecoverBindings(bool topologyEnabled)
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         IConnection connection = await AmqpConnection.CreateAsync(
             ConnectionSettingBuilder.Create()
@@ -467,11 +472,12 @@ await SystemUtils.WaitUntilBindingsBetweenExchangeAndQueueDontExistAsync("exchan
     ///
     /// Only at the end the queue will be removed and bindings should be zero.
     /// </summary>
-    [Fact]
+    [SkippableFact]
     public async Task RemoveAQueueShouldRemoveTheBindings()
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         IConnection connection = await AmqpConnection.CreateAsync(
             ConnectionSettingBuilder.Create()
@@ -529,11 +535,12 @@ await SystemUtils.WaitUntilBindingsBetweenExchangeAndQueueDontExistAsync("e-remo
         await connection.CloseAsync();
     }
 
-    [Fact]
+    [SkippableFact]
     public async Task RemoveAnExchangeShouldRemoveTheBindings()
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         IConnection connection = await AmqpConnection.CreateAsync(
             ConnectionSettingBuilder.Create()
@@ -596,11 +603,12 @@ await SystemUtils.WaitUntilBindingsBetweenExchangeAndQueueDontExistAsync(
     /// <summary>
     /// This test is specific to check if the bindings are removed when a destination exchange is removed.
     /// </summary>
-    [Fact]
+    [SkippableFact]
     public async Task RemoveAnExchangeBoundToAnotherExchangeShouldRemoveTheBindings()
     {
         Assert.Null(_connection);
         Assert.Null(_management);
+        Skip.If(true, "rabbitmq-dotnet-client-87");
 
         IConnection connection = await AmqpConnection.CreateAsync(
             ConnectionSettingBuilder.Create()
@@ -650,4 +658,3 @@ await SystemUtils.WaitUntilBindingsBetweenExchangeAndExchangeDontExistAsync(
         await connection.CloseAsync();
     }
 }
-#endif