Test fixes for Rabbit MQ

src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_1684_separated_handlers_and_conventional_routing.cs

@@ -72,7 +72,7 @@ public Task Consume(Msg message)
     }
 }
 
-[StickyHandler(nameof(ConsumerOne))]
+[StickyHandler(nameof(ConsumerTwo))]
 public class ConsumerTwo : IWolverineHandler
 {
     public void Consume(Msg message)

src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_1716_weird_serialization_issue.cs

@@ -25,7 +25,7 @@ public async Task try_to_reproduce()
     [Fact]
     public void try_to_deserialize_date_string()
     {
-        var time = DateTimeOffset.Parse("2025-10-11 21:58:51:345464 Z");
+        var time = DateTimeOffset.Parse("2025-10-11 21:58:51.345464 Z");
         //var time = XmlConvert.ToDateTime("2025-10-11 21:58:51:345464 Z", XmlDateTimeSerializationMode.Utc);
     }
 

src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_189_fails_if_there_are_many_messages_in_queue_on_startup.cs

@@ -46,7 +46,9 @@ await Host.CreateDefaultBuilder()
 
         var waiter = Bug189Handler.WaitForCompletion(500, 120000);
 
-        using var receiver = Host.CreateDefaultBuilder()
+        // Fire-and-forget the host startup so it doesn't block while processing
+        // queued messages inline during startup
+        var receiverTask = Host.CreateDefaultBuilder()
             .UseWolverine(opts =>
             {
                 opts.UseRabbitMq();
@@ -55,7 +57,17 @@ await Host.CreateDefaultBuilder()
                 opts.ListenToRabbitQueue(queueName).ProcessInline().ListenerCount(5);
             }).StartAsync();
 
-        await waiter;
+        try
+        {
+            await waiter;
+        }
+        finally
+        {
+            if (receiverTask.IsCompletedSuccessfully)
+            {
+                await receiverTask.Result.StopAsync();
+            }
+        }
     }
 
     public record Bug189(Guid Id);

src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/rate_limiting_end_to_end.cs

@@ -54,7 +54,7 @@ public async Task rate_limited_messages_are_delayed_over_rabbitmq()
             await receiver.ResetResourceState();
             await alignToWindowStart(window);
 
-            var bus = publisher.Services.GetRequiredService<IMessageBus>();
+            var bus = publisher.MessageBus();
             await bus.PublishAsync(new RateLimitedMessage());
             await bus.PublishAsync(new RateLimitedMessage());