Update worker timeout

Author: papac

src/Queue/Adapters/QueueAdapter.php

@@ -26,6 +26,13 @@ abstract class QueueAdapter
      */
     protected float $processing_timeout;
 
+    /**
+     * Define the work time out
+     *
+     * @var integer
+     */
+    protected int $timeout = 120;
+
     /**
      * Determine the default watch name
      *
@@ -100,15 +107,26 @@ public function sleep(int $seconds): void
         }
     }
 
+    /**
+     * Set worker timeout
+     *
+     * @param integer $timeout
+     * @return void
+     */
+    public function setTimeout(int $timeout): void
+    {
+        $this->timeout = $timeout;
+    }
+
     /**
      * Update the processing timeout
      *
-     * @param int $timeout
+     * @param int  $timeout
      * @return void
      */
-    public function updateProcessingTimeout(int $timeout = 60): void
+    public function updateProcessingTimeout(?int $timeout = null): void
     {
-        $this->processing_timeout = time() + $timeout;
+        $this->processing_timeout = time() + ($timeout ?? $this->timeout);
     }
 
     /**
@@ -128,7 +146,8 @@ final public function work(int $timeout, int $memory): void
 
         while (true) {
             try {
-                $this->updateProcessingTimeout($timeout);
+                $this->setTimeout($timeout);
+                $this->updateProcessingTimeout();
                 $this->run($this->queue);
             } finally {
                 $this->sleep($this->sleep);

src/Queue/WorkerService.php

@@ -40,7 +40,7 @@ public function run(
         string $queue = "default",
         int $tries = 3,
         int $sleep = 5,
-        int $timeout = 60,
+        int $timeout = 120,
         int $memory = 128
     ): void {
         $this->connection->setQueue($queue);