Custom worker fix (vyuldashev#320)

Dezinger · web-flow · commit f2db8f9d422c · 2020-03-06T23:31:42.000+01:00
diff --git a/src/Queue/Connectors/RabbitMQConnector.php b/src/Queue/Connectors/RabbitMQConnector.php
@@ -86,8 +86,10 @@ public function connect(array $config): Queue
             return new HorizonRabbitMQQueue($context, $config);
         }
 
-        if ($worker instanceof RabbitMQQueue) {
-            return new $worker($context, $config);
+        $customWorker = new $worker($context, $config);
+
+        if ($customWorker instanceof RabbitMQQueue) {
+            return $customWorker;
         }
 
         throw new InvalidArgumentException('Invalid worker.');

Original file line number	Diff line number	Diff line change
`@@ -86,8 +86,10 @@ public function connect(array $config): Queue`
`86`	`86`	`return new HorizonRabbitMQQueue($context, $config);`
`87`	`87`	`}`
`88`	`88`
`89`		`- if ($worker instanceof RabbitMQQueue) {`
`90`		`- return new $worker($context, $config);`
	`89`	`+ $customWorker = new $worker($context, $config);`
	`90`	`+`
	`91`	`+ if ($customWorker instanceof RabbitMQQueue) {`
	`92`	`+ return $customWorker;`
`91`	`93`	`}`
`92`	`94`
`93`	`95`	`throw new InvalidArgumentException('Invalid worker.');`