Hangfire Servisi

var storageOptions = new PostgreSqlStorageOptions
{
    SchemaName              = configuration.GetSection("Services:Hangfire:Schema").Value ?? "hangfire",
    QueuePollInterval       = TimeSpan.FromMilliseconds(200),
    InvisibilityTimeout     = TimeSpan.FromMinutes(5),
    DistributedLockTimeout  = TimeSpan.FromMinutes(5),
    PrepareSchemaIfNecessary= true,
    StartupConnectionMaxRetries = 2,
    AllowDegradedModeWithoutStorage = false,   // storage yoksa uygulama başlamaz
};

services.AddHangfire((provider, conf) =>
    conf.SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
        .UseSimpleAssemblyNameTypeSerializer()
        .UseRecommendedSerializerSettings()
        .UsePostgreSqlStorage(opts =>
            opts.UseNpgsqlConnection(configuration.GetConnectionString("HangfireConnection")),
            storageOptions));

{
  "ConnectionStrings": {
    "HangfireConnection": "Host=localhost;Port=5432;Database=DiyanetCleanArchitecture;Username=postgres;Password=..."
  }
}

{
  "Services": {
    "Hangfire": {
      "Path": "/jobs",
      "DashboardTitle": "DiyanetCleanArchitecture Hangfire Dashboard - Dev",
      "Username": "admin",
      "Password": "admin",
      "Schema": "hangfire",
      "Servers": [
        { "Name": "event-bus",   "WorkerCount": 5, "Queues": [ "event-queue",   "event-queue-dlx" ] },
        { "Name": "command-bus", "WorkerCount": 5, "Queues": [ "command-queue", "command-queue-dlx" ] }
      ]
    }
  }
}

foreach (var server in servers)
{
    services.AddHangfireServer(opt =>
    {
        opt.ServerName = server.Name;
        opt.WorkerCount = server.WorkerCount;
        opt.CancellationCheckInterval = TimeSpan.FromSeconds(10);
        opt.Queues = server.Queues;
    });
}

services.AddScoped<ICommandBus, CommandBus>();
services.AddScoped<ICommandExecuter, CommandExecuter>();
services.AddScoped<IEventBus, EventBus>();
services.AddScoped<IEventDispatcher, EventDispatcher>();
services.AddSingleton<ITimeZoneResolver>(new TimeZoneConverterResolver());

public static IApplicationBuilder UseHangfireDashboard(this IApplicationBuilder app, IConfiguration configuration)
{
    var authUser = new BasicAuthAuthorizationFilter(new BasicAuthAuthorizationFilterOptions
    {
        RequireSsl = false, SslRedirect = false, LoginCaseSensitive = true,
        Users = new[] { new BasicAuthAuthorizationUser
        {
            Login = configuration.GetSection("Services:Hangfire:Username").Value,
            PasswordClear = configuration.GetSection("Services:Hangfire:Password").Value
        }}
    });

    app.UseHangfireDashboard(configuration.GetSection("Services:Hangfire:Path").Value, new DashboardOptions
    {
        DashboardTitle = configuration.GetSection("Services:Hangfire:DashboardTitle").Value,
        IsReadOnlyFunc = ctx => false,
        Authorization = new[] { authUser }
    });

    return app;
}

services.AddHealthChecks()
    .AddHangfire(opts => opts.MinimumAvailableServers = 1,
        name: "hangfire",
        failureStatus: HealthStatus.Degraded,
        tags: new[] { HealthCheckTags.Ready, HealthCheckTags.Jobs });

// Tek seferlik (fire-and-forget)
BackgroundJob.Enqueue<IMyJob>(j => j.RunAsync(payload));

// Gecikmeli
BackgroundJob.Schedule<IMyJob>(j => j.RunAsync(payload), TimeSpan.FromMinutes(10));

// Periyodik (cron)
RecurringJob.AddOrUpdate<IMyJob>("daily-cleanup", j => j.CleanupAsync(), Cron.Daily);

await _commandBus.SendAsync(new MyCommand(...));   // command-queue
await _eventBus.PublishAsync(new MyEvent(...));     // event-queue