Merge pull request #13 from lothid/master

makasim · web-flow · commit d832e533ed4b · 2019-06-14T10:05:30.000+03:00
Fix Worker parent parameter when driver is not interop
diff --git a/src/Worker.php b/src/Worker.php
@@ -49,7 +49,7 @@ public function daemon($connectionName, $queueNames, WorkerOptions $options)
         $this->interop = $this->queue instanceof Queue;
 
         if (false == $this->interop) {
-            parent::daemon($connectionName, $this->queue, $options);
+            parent::daemon($connectionName, $this->queueNames, $options);
         }
 
         $context = $this->queue->getQueueInteropContext();
@@ -76,7 +76,7 @@ public function runNextJob($connectionName, $queueNames, WorkerOptions $options)
         $this->interop = $this->queue instanceof Queue;
 
         if (false == $this->interop) {
-            parent::daemon($connectionName, $this->queue, $options);
+            parent::daemon($connectionName, $this->queueNames, $options);
         }
 
         $context = $this->queue->getQueueInteropContext();

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