added debug while init.

This commit is contained in:
ruberoid 2024-04-04 22:35:43 +04:00
parent fb5a4bb20b
commit 23ec10a012

View File

@ -29,6 +29,14 @@ public class Startup
builder.Transport(t =>
{
var rebusOptions = ctx.GetRequiredService<IOptions<RebusRabbitMqOptions>>().Value;
Console.WriteLine("*** DEBUG ***");
Console.WriteLine(Environment.GetEnvironmentVariable("RebusRabbitMqOptions__ConnectionString"));
Console.WriteLine(rebusOptions.ConnectionString);
Console.WriteLine("*** DEBUG ***");
t.UseRabbitMq(rebusOptions.ConnectionString, rebusOptions.InputQueueName)
.DefaultQueueOptions(queue => queue.SetDurable(true))
.ExchangeNames(rebusOptions.DirectExchangeName, rebusOptions.TopicsExchangeName);