pass dispatchAfterCommit into custom worker constructor wihtout breaking changes

README.md

@@ -254,6 +254,62 @@ class RabbitMQJob extends BaseJob
 }
 ```
 
+### Use your own RabbitMQQueue class
+
+To use own RabbitMQQueue set `RABBITMQ_WORKER` (or `worker` param) to your queue class.
+
+```php
+RABBITMQ_WORKER='App\\Services\\CustomRabbitMQQueue'
+```
+or
+
+```php
+    'worker' => env('RABBITMQ_WORKER', App\Services\CustomRabbitMQQueue::class),
+```
+
+where queue class is defined like
+```php
+<?php
+
+namespace App\Queue\Jobs;
+
+use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
+
+class CustomRabbitMQQueue extends RabbitMQQueue
+{
+    public function __construct(
+        AbstractConnection $connection,
+        string $default,
+        array $options = []
+    ) {
+```
+
+for compatibility queue constructor doesn't receive `$dispatchAfterCommit`, to use parent contructor use extra parameter in config
+```php
+    'worker' => env('RABBITMQ_WORKER', App\Services\CustomRabbitMQQueue::class),
+    'custom_worker_type' =>  'with_dispatch_after_commit',
+```
+
+then you can reuse parent constructor
+```php
+<?php
+
+namespace App\Queue\Jobs;
+
+use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
+
+class CustomRabbitMQQueue extends RabbitMQQueue
+{
+    public function __construct(
+        AbstractConnection $connection,
+        string $default,
+        bool $dispatchAfterCommit = false,
+        array $options = []
+    ) {
+```
+
+or skip constructor entirely
+
 ## Laravel Usage
 
 Once you completed the configuration you can use the Laravel Queue API. If you used other queue drivers you do not need to

src/Queue/Connectors/RabbitMQConnector.php

@@ -42,6 +42,7 @@ public function connect(array $config): Queue
 
         $queue = $this->createQueue(
             Arr::get($config, 'worker', 'default'),
+            Arr::get($config, 'custom_worker_type', 'default'),
             $connection,
             $config['queue'],
             Arr::get($config, 'after_commit', false),
@@ -95,6 +96,7 @@ protected function createConnection(array $config): AbstractConnection
      */
     protected function createQueue(
         string $worker,
+        string $customWorkerType,
         AbstractConnection $connection,
         string $queue,
         bool $dispatchAfterCommit,
@@ -106,7 +108,12 @@ protected function createQueue(
             case 'horizon':
                 return new HorizonRabbitMQQueue($connection, $queue, $dispatchAfterCommit, $options);
             default:
-                return new $worker($connection, $queue, $options);
+                switch ($customWorkerType) {
+                    case 'with_dispatch_after_commit':
+                        return new $worker($connection, $queue, $dispatchAfterCommit, $options);
+                    default:
+                        return new $worker($connection, $queue, $options);
+                }
         }
     }