diff --git a/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_1684_separated_handlers_and_conventional_routing.cs b/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_1684_separated_handlers_and_conventional_routing.cs index 253872eb3..ac941e067 100644 --- a/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_1684_separated_handlers_and_conventional_routing.cs +++ b/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) diff --git a/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_1716_weird_serialization_issue.cs b/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_1716_weird_serialization_issue.cs index 6777c4bcb..78f467d82 100644 --- a/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_1716_weird_serialization_issue.cs +++ b/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); } diff --git a/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_189_fails_if_there_are_many_messages_in_queue_on_startup.cs b/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_189_fails_if_there_are_many_messages_in_queue_on_startup.cs index 9ddd72b35..7ff01b02d 100644 --- a/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/Bugs/Bug_189_fails_if_there_are_many_messages_in_queue_on_startup.cs +++ b/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); diff --git a/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/rate_limiting_end_to_end.cs b/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/rate_limiting_end_to_end.cs index 6afa8a401..b99aaea68 100644 --- a/src/Transports/RabbitMQ/Wolverine.RabbitMQ.Tests/rate_limiting_end_to_end.cs +++ b/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(); + var bus = publisher.MessageBus(); await bus.PublishAsync(new RateLimitedMessage()); await bus.PublishAsync(new RateLimitedMessage());