When i run the following test it gets blocked and i can't understand why.
I'm using Stop()
and not StopAsync(
) because in our application, the Stop()
is used inside a Dispose()
method
var queueUri = new Uri($"rabbitmq://localhost/some-queue"); var rabbitMqHostSettings = queueUri.GetHostSettings(); var receiveSettings = queueUri.GetReceiveSettings(); IBusControl bus = Bus.Factory.CreateUsingRabbitMq(sbc => { var host = sbc.Host(rabbitMqHostSettings); sbc.ReceiveEndpoint(host, receiveSettings.QueueName, ep => { }); }); bus.Start(); await bus.Publish(new DummyMessage() { ID = 1 }); bus.Stop();