Fixing broken tests.

microting · May 29, 2024 · 8f41763 · 8f41763
1 parent 060007e
commit 8f41763
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 17 deletions.
diff --git a/Rebus.RabbitMq.Tests/Rebus.RabbitMq.Tests.csproj b/Rebus.RabbitMq.Tests/Rebus.RabbitMq.Tests.csproj
@@ -16,8 +16,9 @@
 			<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
 		</PackageReference>
 		<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
-		<PackageReference Include="Microting.Rebus" Version="8.0.2" />
-		<PackageReference Include="Microting.Rebus.Tests.Contracts" Version="8.0.2" />
+		<PackageReference Include="Microting.Rebus" Version="8.0.4" />
+		<PackageReference Include="Microting.Rebus.Tests.Contracts" Version="8.0.4" />
+		<PackageReference Include="Testcontainers.RabbitMq" Version="3.8.0" />
 	</ItemGroup>
 	<ItemGroup>
 		<Folder Include="Internals\" />

diff --git a/Rebus.RabbitMq.Tests/TestRabbitExpress.cs b/Rebus.RabbitMq.Tests/TestRabbitExpress.cs
@@ -49,19 +49,8 @@ public async Task TestPerformance(int messageCount, bool express, bool enableBat
             .Transport(t => t.UseRabbitMq(RabbitMqTransportFactory.ConnectionString, _queueName).SetBatchSize(enableBatching ? 100 : 1))
             .Options(o => o.SetMaxParallelism(100))
             .Start();
-    }
-
-    [TestCase(10, true)]
-    [TestCase(10, false)]
-    [TestCase(10000, true)]
-    [TestCase(10000, false)]
-    public async Task TestPerformance(int messageCount, bool express)
-    {
-        var receivedMessages = 0L;
-
-        _bus.Advanced.Workers.SetNumberOfWorkers(0);
 
-        _activator.Handle<object>(async _ => Interlocked.Increment(ref receivedMessages));
+        bus.Advanced.Workers.SetNumberOfWorkers(0);
 
         var stopwatch = Stopwatch.StartNew();
 
@@ -71,7 +60,6 @@ public async Task TestPerformance(int messageCount, bool express)
         {
             using var scope = new RebusTransactionScope();
 
-
             foreach (var msg in batch)
             {
                 await bus.SendLocal(msg);
@@ -118,4 +106,4 @@ public ExpressAttribute() : base(Headers.Express, "")
         {
         }
     }
-}
+}
diff --git a/Rebus.RabbitMq/Rebus.RabbitMq.csproj b/Rebus.RabbitMq/Rebus.RabbitMq.csproj
@@ -17,7 +17,7 @@
     	<PackageId>Microting.Rebus.RabbitMq</PackageId>
 	</PropertyGroup>
 	<ItemGroup>
-		<PackageReference Include="Microting.Rebus" Version="8.0.2" />
+		<PackageReference Include="Microting.Rebus" Version="8.0.4" />
 		<PackageReference Include="RabbitMq.Client" Version="6.8.1" />
 	</ItemGroup>
 	<ItemGroup>