connectors: add custom worker check

pmatteo · web-flow · commit c324645319e9 · 2019-07-25T18:06:32.000+02:00
diff --git a/src/Queue/Connectors/RabbitMQConnector.php b/src/Queue/Connectors/RabbitMQConnector.php
@@ -85,6 +85,10 @@ public function connect(array $config): Queue
 
             return new HorizonRabbitMQQueue($context, $config);
         }
+        
+        if (class_exists($worker)) {
+            return new $worker($context, $config);
+        }
 
         throw new InvalidArgumentException('Invalid worker.');
     }

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