From cbf51375f732c51d5433f82e7fba8e336d823b0f Mon Sep 17 00:00:00 2001
From: Serhii Fomenko <fehomehal@gmail.com>
Date: Mon, 5 Jul 2021 18:52:13 +0300
Subject: [PATCH] Reset SIGALRM when job is processed

---
 src/Worker.php | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/src/Worker.php b/src/Worker.php
index a912c61..46d6bce 100644
--- a/src/Worker.php
+++ b/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) {