* use Spiral\RoadRunner\Environment; * use Spiral\RoadRunner\Environment\Mode; * * $env = Environment::fromGlobals(); * if ($env->getMode() !== Mode::MODE_JOBS) { * throw new RuntimeException('Can not create Jobs Consumer'); * } * * $consumer = new Consumer(...); * */ final class Consumer implements ConsumerInterface { private readonly WorkerInterface $worker; private readonly ReceivedTaskFactoryInterface $receivedTaskFactory; public function __construct( ?WorkerInterface $worker = null, ?ReceivedTaskFactoryInterface $receivedTaskFactory = null, ) { $this->worker = $worker ?? Worker::create(); $this->receivedTaskFactory = $receivedTaskFactory ?? new ReceivedTaskFactory($this->worker); } /** * @throws ReceivedTaskException * @throws SerializationException * @psalm-suppress ArgumentTypeCoercion */ public function waitTask(): ?ReceivedTaskInterface { $payload = $this->worker->waitPayload(); if ($payload === null) { return null; } return $this->receivedTaskFactory->create($payload); } }