* Increase wait time in test for CI.

* Ensure toxiproxy proxy is deleted before trying to create it.
rabbitmq · Mar 27, 2024 · dd9da1f · dd9da1f
1 parent d459310
commit dd9da1f
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 7 deletions.
diff --git a/projects/Test/Integration/TestConnectionShutdown.cs b/projects/Test/Integration/TestConnectionShutdown.cs
@@ -94,7 +94,13 @@ public async Task TestDisposedWithSocketClosedOutOfBand()
 
             _conn.Dispose();
             _conn = null;
-            await WaitAsync(tcs, TimeSpan.FromSeconds(3), "channel shutdown");
+
+            TimeSpan waitSpan = TimeSpan.FromSeconds(3);
+            if (IsRunningInCI)
+            {
+                waitSpan = TimeSpan.FromSeconds(10);
+            }
+            await WaitAsync(tcs, waitSpan, "channel shutdown");
         }
 
         [Fact]

diff --git a/projects/Test/Integration/TestToxiproxy.cs b/projects/Test/Integration/TestToxiproxy.cs
@@ -84,7 +84,7 @@ public TestToxiproxy(ITestOutputHelper output) : base(output)
             }
         }
 
-        public override Task InitializeAsync()
+        public override async Task InitializeAsync()
         {
             // NB: nothing to do here since each test creates its own factory,
             // connections and channels
@@ -94,11 +94,15 @@ public override Task InitializeAsync()
 
             if (AreToxiproxyTestsEnabled)
             {
-                return _proxyClient.AddAsync(_rmqProxy);
-            }
-            else
-            {
-                return Task.CompletedTask;
+                try
+                {
+                    await _proxyClient.DeleteAsync(_rmqProxy);
+                }
+                catch
+                {
+                }
+
+                await _proxyClient.AddAsync(_rmqProxy);
             }
         }