Program.cs

using Hangfire;
using Hangfire.PostgreSql;
using HangfireDemo;
using HangfireDemo.GraphQL;


var builder = WebApplication.CreateBuilder(args);

var configuration = builder.Configuration;


builder.Services.AddHangfire((serviceProvider, config) =>
{
    config.UsePostgreSqlStorage(c =>
        c.UseNpgsqlConnection(configuration.GetConnectionString("HangfireConnection")));

   // config.UseActivator(new TestJobActivator(serviceProvider.GetRequiredService<IServiceScopeFactory>()));

    //config.UseFilter(new ExampleJobFilter());
});

//Server where you don't set any options will use a "default" queue and use 20 workers.
builder.Services.AddHangfireServer();


builder.Services.AddHangfireServer(options =>
{
    options.SchedulePollingInterval = TimeSpan.FromSeconds(2);
    options.Queues = [Constants.FastQueue];
});


builder.Services.AddHangfireServer(options =>
{
    options.Queues = [Constants.SlowQueue, Constants.QueueNumberTwo];
    options.ServerName = "MyLimitedServer";
    options.WorkerCount = 5;
});




builder.Services.AddScoped<BackgroundJobService>();
builder.Services.AddScoped<BulkExampleService>();

builder.Services
    .AddGraphQLServer()
    .AddQueryType<Query>()
    .AddMutationType<Mutation>()
    .AddSubscriptionType<Subscription>()
    .AddInMemorySubscriptions();

var app = builder.Build();

// Configure the HTTP request pipeline.
if (!app.Environment.IsDevelopment())
{
    app.UseExceptionHandler("/Error");
}

app.UseRouting();

app.UseHangfireDashboard();

app.UseWebSockets();
app.MapGraphQL();

app.Run();