vyuldashev#225 laravel horizon support

Author: vyuldashev

src/Queue/Connectors/RabbitMQConnector.php

@@ -11,6 +11,7 @@
 use Illuminate\Queue\Events\WorkerStopping;
 use Enqueue\AmqpTools\RabbitMqDlxDelayStrategy;
 use Illuminate\Queue\Connectors\ConnectorInterface;
+use InvalidArgumentException;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\RabbitMQQueue as HorizonRabbitMQQueue;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
 use Interop\Amqp\AmqpConnectionFactory as InteropAmqpConnectionFactory;
@@ -48,18 +49,18 @@ public function connect(array $config): Queue
 
         /** @var AmqpConnectionFactory $factory */
         $factory = new $factoryClass([
-            'dsn' => $config['dsn'],
-            'host' => $config['host'],
-            'port' => $config['port'],
-            'user' => $config['login'],
-            'pass' => $config['password'],
-            'vhost' => $config['vhost'],
-            'ssl_on' => $config['ssl_params']['ssl_on'],
-            'ssl_verify' => $config['ssl_params']['verify_peer'],
-            'ssl_cacert' => $config['ssl_params']['cafile'],
-            'ssl_cert' => $config['ssl_params']['local_cert'],
-            'ssl_key' => $config['ssl_params']['local_key'],
-            'ssl_passphrase' => $config['ssl_params']['passphrase'],
+            'dsn' => Arr::get($config, 'dsn'),
+            'host' => Arr::get($config, 'host', '127.0.0.1'),
+            'port' => Arr::get($config, 'port', 5672),
+            'user' => Arr::get($config, 'login', 'guest'),
+            'pass' => Arr::get($config, 'password', 'guest'),
+            'vhost' => Arr::get($config, 'vhost', '/'),
+            'ssl_on' => Arr::get($config, 'ssl_params.ssl_on', false),
+            'ssl_verify' => Arr::get($config, 'ssl_params.verify_peer', true),
+            'ssl_cacert' => Arr::get($config, 'ssl_params.ca_file'),
+            'ssl_cert' => Arr::get($config, 'ssl_params.local_cert'),
+            'ssl_key' => Arr::get($config, 'ssl_params.local_key'),
+            'ssl_passphrase' => Arr::get($config, 'ssl_params.passphrase'),
         ]);
 
         if ($factory instanceof DelayStrategyAware) {
@@ -75,12 +76,14 @@ public function connect(array $config): Queue
 
         $worker = Arr::get($config, 'worker', 'default');
 
-        if($worker === 'default') {
+        if ($worker === 'default') {
             return new RabbitMQQueue($context, $config);
         }
 
-        if($worker === 'horizon') {
+        if ($worker === 'horizon') {
             return new HorizonRabbitMQQueue($context, $config);
         }
+
+        throw new InvalidArgumentException('Invalid worker.');
     }
 }