Merge pull request #20 from vitaliy-gituser/master

makasim · web-flow · commit 2c4ac43e0e4c · 2020-11-13T18:05:53.000+02:00
When using this library and if another queue driver is used, in class…
diff --git 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();

Original file line number	Diff line number	Diff line change
`@@ -50,6 +50,7 @@ public function daemon($connectionName, $queueNames, WorkerOptions $options)`
`50`	`50`
`51`	`51`	`if (false == $this->interop) {`
`52`	`52`	`parent::daemon($connectionName, $this->queueNames, $options);`
	`53`	`+ return;`
`53`	`54`	`}`
`54`	`55`
`55`	`56`	`$context = $this->queue->getQueueInteropContext();`
`@@ -77,6 +78,7 @@ public function runNextJob($connectionName, $queueNames, WorkerOptions $options)`
`77`	`78`
`78`	`79`	`if (false == $this->interop) {`
`79`	`80`	`parent::daemon($connectionName, $this->queueNames, $options);`
	`81`	`+ return;`
`80`	`82`	`}`
`81`	`83`
`82`	`84`	`$context = $this->queue->getQueueInteropContext();`