diff --git a/pkg/gearman/GearmanConsumer.php b/pkg/gearman/GearmanConsumer.php index 7d4bcef23..68f15e045 100644 --- a/pkg/gearman/GearmanConsumer.php +++ b/pkg/gearman/GearmanConsumer.php @@ -59,7 +59,7 @@ public function receive(int $timeout = 0): ?Message $message = GearmanMessage::jsonUnserialize($job->workload()); }); - while ($this->worker->work()); + $this->worker->work(); } finally { restore_error_handler(); }