Merge pull request #998 from arep/arep-patch-1

makasim · web-flow · commit 8f86cf9feedb · 2019-12-25T23:55:40.000+02:00
Gearman Consumer receive should only fetch one message
diff --git 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();
         }

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ public function receive(int $timeout = 0): ?Message`
`59`	`59`	`$message = GearmanMessage::jsonUnserialize($job->workload());`
`60`	`60`	`});`
`61`	`61`
`62`		`- while ($this->worker->work());`
	`62`	`+ $this->worker->work();`
`63`	`63`	`} finally {`
`64`	`64`	`restore_error_handler();`
`65`	`65`	`}`