Update FairQueueServiceProvider.php

aloware · Jun 18, 2022 · 06531ee · 06531ee
1 parent c2dfcaf
commit 06531ee
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/FairQueueServiceProvider.php b/src/FairQueueServiceProvider.php
@@ -92,9 +92,13 @@ protected function registerQueueEvents(): void
         Queue::after(function (JobProcessed $event) {
             $redis = FairQueue::getConnection();
             $payload = $event->job->payload();
+            if (!isset($payload['data']) || !isset($payload['data']['command'])) {
+                return;
+            }
             $command = unserialize($payload['data']['command']);
-            if(!$command instanceof FairSignalJob)
+            if (!$command instanceof FairSignalJob) {
                 return;
+            }
             $queue = $command->queue;
             $partition = $command->partition;
             $past_minute_key = $this->partitionProcessedJobsInPastMinutesKey($queue, $partition, 1);