Refactor queue assignment in dispatch function

hyperf · May 27, 2024 · 6316865 · 6316865
1 parent 821c8a1
commit 6316865
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/async-queue/src/Functions.php b/src/async-queue/src/Functions.php
@@ -21,7 +21,7 @@ function dispatch(JobInterface $job, ?int $delay = null, ?int $maxAttempts = nul
         $job->setMaxAttempts($maxAttempts);
     }
 
-    $queue = (fn ($queue) => $this->queue ?? $queue ?? 'default')->call($job, $queue);
+    $queue ??= (fn () => $this->queue ?? 'default')->call($job);
 
     return ApplicationContext::getContainer()
         ->get(DriverFactory::class)