/
afanasevn
/
MaxSystems
Обзор
Документация
Войти
/
afanasevn
/
MaxSystems
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
src/MaxSystems.Worker/Program.cs
41 строка
2 KB
IBS\NAfanasev
Worker: SMTP notifications
22 июн 2026, 17:39
22 июн 2026, 17:39
f147337
Код
Авторство
О чём код?
using MaxSystems.Infrastructure; using MaxSystems.Infrastructure.Configuration; using MaxSystems.Worker.Integration; namespace MaxSystems.Worker; /// <summary> /// Точка входа Worker: слушает integration-очереди RabbitMQ и обновляет журнал доставки. /// </summary> public static class Program { /// <summary>Запуск Worker: миграции, подписка на очереди и provisioning RabbitMQ.</summary> public static async Task Main(string[] args) { if (!string.Equals( Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT"), "Testing", StringComparison.OrdinalIgnoreCase)) { EnvLoader.LoadFromRepositoryRoot(); } var builder = Host.CreateApplicationBuilder(args); var connectionString = ConnectionStringConfiguration.GetDefaultConnection(builder.Configuration); var rabbitMqConnectionString = ConnectionStringConfiguration.GetRabbitMqConnection(builder.Configuration); builder.Services.AddInfrastructure(connectionString); builder.Services.AddWorkerServices(builder.Configuration); builder.ConfigureWorkerWolverine(connectionString, rabbitMqConnectionString); var host = builder.Build(); await host.Services.MigrateDatabaseAsync(); await host.StartAsync(); await IntegrationRabbitMqProvisioner.EnsureBindingsAsync(rabbitMqConnectionString); await host.WaitForShutdownAsync(); } }