Adds Job::setMaxAttempts and dispatch helper function (#5950)

Co-authored-by: 李铭昕 <[email protected]>

Author: huangdijia

composer.json

@@ -32,6 +32,9 @@
         "hyperf/process": "Auto register the consumer process for server."
     },
     "autoload": {
+        "files": [
+            "src/Functions.php"
+        ],
         "psr-4": {
             "Hyperf\\AsyncQueue\\": "src/"
         }

src/Functions.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://hyperf.wiki
+ * @contact  [email protected]
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
+namespace Hyperf\AsyncQueue;
+
+use Hyperf\AsyncQueue\Driver\DriverFactory;
+use Hyperf\Context\ApplicationContext;
+
+function dispatch(JobInterface $job, ?int $delay = null, ?int $maxAttempts = null, ?string $pool = null): bool
+{
+    if (is_int($maxAttempts)) {
+        $job->setMaxAttempts($maxAttempts);
+    }
+
+    return ApplicationContext::getContainer()
+        ->get(DriverFactory::class)
+        ->get($pool ?? 'default')
+        ->push($job, $delay ?? 0);
+}

src/Job.php

@@ -18,6 +18,13 @@ abstract class Job implements JobInterface, CompressInterface, UnCompressInterfa
 {
     protected int $maxAttempts = 0;
 
+    public function setMaxAttempts(int $maxAttempts): static
+    {
+        $this->maxAttempts = $maxAttempts;
+
+        return $this;
+    }
+
     public function getMaxAttempts(): int
     {
         return $this->maxAttempts;

src/JobInterface.php

@@ -18,5 +18,7 @@ interface JobInterface
      */
     public function handle();
 
+    public function setMaxAttempts(int $maxAttempts): static;
+
     public function getMaxAttempts(): int;
 }