diff --git a/src/Worker.php b/src/Worker.php index d85a4a3..55b6210 100644 --- a/src/Worker.php +++ b/src/Worker.php @@ -50,6 +50,7 @@ public function daemon($connectionName, $queueNames, WorkerOptions $options) if (false == $this->interop) { parent::daemon($connectionName, $this->queueNames, $options); + return; } $context = $this->queue->getQueueInteropContext(); @@ -77,6 +78,7 @@ public function runNextJob($connectionName, $queueNames, WorkerOptions $options) if (false == $this->interop) { parent::daemon($connectionName, $this->queueNames, $options); + return; } $context = $this->queue->getQueueInteropContext();