make it work with other amqp implementations.

Author: makasim

README.md

@@ -11,19 +11,15 @@ RabbitMQ Queue driver for Laravel
 1. Install this package via composer using:
 
 ```
-composer require vladimir-yuldashev/laravel-queue-rabbitmq:5.5
+composer require vladimir-yuldashev/laravel-queue-rabbitmq:^6
 ```
 
 2. Add these properties to `.env` with proper values:
 
 ```
 QUEUE_DRIVER=rabbitmq
 
-RABBITMQ_HOST=127.0.0.1
-RABBITMQ_PORT=5672
-RABBITMQ_VHOST=/
-RABBITMQ_LOGIN=guest
-RABBITMQ_PASSWORD=guest
+RABBITMQ_DSN=amqp://guest:guest@127.0.0.1:5672/%2F
 RABBITMQ_QUEUE=queue_name
 ```
 

config/rabbitmq.php

@@ -9,6 +9,16 @@
 
     'driver' => 'rabbitmq',
 
+    'dsn' => env('RABBITMQ_DSN', null),
+
+    /*
+     * Could be one a class that implements \Interop\Amqp\AmqpConnectionFactory for example:
+     *  - \EnqueueAmqpExt\AmqpConnectionFactory if you install enqueue/amqp-ext
+     *  - \EnqueueAmqpLib\AmqpConnectionFactory if you install enqueue/amqp-lib
+     *  - \EnqueueAmqpBunny\AmqpConnectionFactory if you install enqueue/amqp-bunny
+     */
+    'factory_class' => \Enqueue\AmqpLib\AmqpConnectionFactory::class,
+
     'host' => env('RABBITMQ_HOST', '127.0.0.1'),
     'port' => env('RABBITMQ_PORT', 5672),
 

src/Queue/Connectors/RabbitMQConnector.php

@@ -7,6 +7,7 @@
 use Illuminate\Contracts\Queue\Queue;
 use Illuminate\Queue\Connectors\ConnectorInterface;
 use Illuminate\Queue\Events\WorkerStopping;
+use Interop\Amqp\AmqpConnectionFactory as InteropAmqpConnectionFactory;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
 
 class RabbitMQConnector implements ConnectorInterface
@@ -20,7 +21,14 @@ class RabbitMQConnector implements ConnectorInterface
      */
     public function connect(array $config): Queue
     {
-        $factory = new AmqpConnectionFactory([
+        $factoryClass = $config['factory_class'];
+        if (false == class_exists($factoryClass) || false == (new \ReflectionClass($factoryClass))->implementsInterface(InteropAmqpConnectionFactory::class)) {
+            throw new \LogicException(sprintf('The factory_class option has to be valid class that implements "%s"', InteropAmqpConnectionFactory::class));
+        }
+
+
+        $factory = new $factoryClass([
+            'dsn' => $config['dsn'],
             'host' => $config['host'],
             'port' => $config['port'],
             'user' => $config['login'],