Merge pull request #23 from fehomeh/fix-sigalarm-processing

Reset SIGALRM when job is processed

Author: makasim

src/Worker.php

@@ -3,24 +3,26 @@
 
 use Enqueue\Consumption\ChainExtension;
 use Enqueue\Consumption\Context\MessageReceived;
+use Enqueue\Consumption\Context\MessageResult;
 use Enqueue\Consumption\Context\PostMessageReceived;
 use Enqueue\Consumption\Context\PreConsume;
 use Enqueue\Consumption\Context\Start;
 use Enqueue\Consumption\Extension\LimitConsumedMessagesExtension;
 use Enqueue\Consumption\MessageReceivedExtensionInterface;
+use Enqueue\Consumption\MessageResultExtensionInterface;
 use Enqueue\Consumption\PostMessageReceivedExtensionInterface;
 use Enqueue\Consumption\PreConsumeExtensionInterface;
 use Enqueue\Consumption\QueueConsumer;
 use Enqueue\Consumption\Result;
 use Enqueue\Consumption\StartExtensionInterface;
-use Enqueue\LaravelQueue\Queue;
 use Illuminate\Queue\WorkerOptions;
 
 class Worker extends \Illuminate\Queue\Worker implements
     StartExtensionInterface,
     PreConsumeExtensionInterface,
     MessageReceivedExtensionInterface,
-    PostMessageReceivedExtensionInterface
+    PostMessageReceivedExtensionInterface,
+    MessageResultExtensionInterface
 {
     protected $connectionName;
 
@@ -144,6 +146,13 @@ public function onPostMessageReceived(PostMessageReceived $context): void
         }
     }
 
+    public function onResult(MessageResult $context): void
+    {
+        if ($this->supportsAsyncSignals()) {
+            $this->resetTimeoutHandler();
+        }
+    }
+
     public function stop($status = 0)
     {
         if ($this->interop) {