Limit polling queries with a semaphore for all configurations

Queries used for sliding invisibility timeout-based fetching are unified now, and we can use the same implementation for sub- and over second polling delay configured. Possibly relates to HangfireIO#2120.
cezar-pimentel · Jun 7, 2024 · 37736c0 · 37736c0
1 parent 4bd4da9
commit 37736c0
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/Hangfire.SqlServer/SqlServerJobQueue.cs b/src/Hangfire.SqlServer/SqlServerJobQueue.cs
@@ -131,11 +131,8 @@ private SqlServerTimeoutJob DequeueUsingSlidingInvisibilityTimeout(string[] queu
 
                 try
                 {
-                    if (useLongPolling)
-                    {
-                        semaphore = Semaphores.GetOrAdd(resource, CreateSemaphoreFunc);
-                        semaphore.Wait(cancellationToken);
-                    }
+                    semaphore = Semaphores.GetOrAdd(resource, CreateSemaphoreFunc);
+                    semaphore.Wait(cancellationToken);
 
                     while (!cancellationToken.IsCancellationRequested)
                     {