Support to specify the queue name based on the job. (#6538)

Co-authored-by: 李铭昕 <715557344@qq.com>

Author: huangdijia

src/Functions.php

@@ -15,14 +15,16 @@
 use Hyperf\AsyncQueue\Driver\DriverFactory;
 use Hyperf\Context\ApplicationContext;
 
-function dispatch(JobInterface $job, ?int $delay = null, ?int $maxAttempts = null, ?string $pool = null): bool
+function dispatch(JobInterface $job, ?int $delay = null, ?int $maxAttempts = null, ?string $queue = null): bool
 {
     if (is_int($maxAttempts)) {
         $job->setMaxAttempts($maxAttempts);
     }
 
+    $queue ??= $job->getQueueName();
+
     return ApplicationContext::getContainer()
         ->get(DriverFactory::class)
-        ->get($pool ?? 'default')
+        ->get($queue)
         ->push($job, $delay ?? 0);
 }

src/Job.php

@@ -57,4 +57,9 @@ public function compress(): static
 
         return $this;
     }
+
+    public function getQueueName(): string
+    {
+        return 'default';
+    }
 }

src/JobInterface.php

@@ -26,4 +26,6 @@ public function handle();
     public function setMaxAttempts(int $maxAttempts): static;
 
     public function getMaxAttempts(): int;
+
+    public function getQueueName(): string;
 }