r support for timeout

Author: dusterio

src/Controllers/WorkerController.php

@@ -130,10 +130,9 @@ public function queue(Request $request, WorkerInterface $worker, Container $lara
         ]);
 
         $worker->process(
-            $request->header('X-Aws-Sqsd-Queue'), $job, [
-                'maxTries' => $this->tryToExtractAttempts($body),
+            $request->header('X-Aws-Sqsd-Queue'), $job, array_merge([
                 'delay' => 0
-            ]
+            ],  $this->tryToExtractOptions($body))
         );
 
         return $this->response([
@@ -145,14 +144,23 @@ public function queue(Request $request, WorkerInterface $worker, Container $lara
      * @param $input
      * @return int
      */
-    private function tryToExtractAttempts($input)
+    private function tryToExtractOptions($input)
     {
-        // Try to extract $tries integer value of the listener from the serialized job body
+        $parameters = [
+            'maxTries' => 1,
+            'timeout' => 60
+        ];
+
+        // Try to extract listener class options from the serialized job body
         if (preg_match('/tries\\\\\\\\\\\\";i:(?<attempts>\d+);/', $input, $matches)) {
-            return intval($matches['attempts']);
+            $parameters['maxTries'] = intval($matches['attempts']);
+        }
+
+        if (preg_match('/timeout\\\\\\\\\\\\";i:(?<timeout>\d+);/', $input, $matches)) {
+            $parameters['timeout'] = intval($matches['timeout']);
         }
 
-        return 0;
+        return $parameters;
     }
 
     /**

src/Wrappers/Laravel7Worker.php

@@ -31,7 +31,7 @@ public function __construct(Worker $worker, Cache $cache)
      */
     public function process($queue, $job, array $options)
     {
-        $workerOptions = new WorkerOptions('default', $options['delay'], 128, 60, 3, $options['maxTries']);
+        $workerOptions = new WorkerOptions('default', $options['delay'], 128, $options['timeout'], 3, $options['maxTries']);
 
         $this->worker->process(
             $queue, $job, $workerOptions