Adds optional arguments to queue_declare().

RabbitMQ queues can be created with additional arguments. If client
connects to a queue that was created with these additional arguments
an exception is thrown:

PRECONDITION_FAILED - inequivalent arg 'x-max-length' for queue
'queue_name' in vhost '/': received none but current is the value
'10000000' of type 'long'

Author: Ratko Rudic

config/rabbitmq.php

@@ -39,6 +39,7 @@
         'durable'     => env('RABBITMQ_QUEUE_DURABLE', true),
         'exclusive'   => env('RABBITMQ_QUEUE_EXCLUSIVE', false),
         'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false),
+        'arguments'   => env('RABBITMQ_QUEUE_ARGUMENTS', false),
     ],
     'exchange_params' => [
         'name' => env('RABBITMQ_EXCHANGE_NAME', null),

src/Queue/RabbitMQQueue.php

@@ -229,7 +229,9 @@ private function declareQueue($name)
                 $this->configQueue['passive'],
                 $this->configQueue['durable'],
                 $this->configQueue['exclusive'],
-                $this->configQueue['auto_delete']
+                $this->configQueue['auto_delete'],
+                false,
+                $this->configQueue['arguments']
             );
 
             // bind queue to the exchange
@@ -268,18 +270,20 @@ private function declareDelayedQueue($destination, $delay)
 
         // declare queue
         if (!in_array($name, $this->declaredQueues, true)) {
+            $queueArguments = array_merge([
+                    'x-dead-letter-exchange'    => $destinationExchange,
+                    'x-dead-letter-routing-key' => $destination,
+                    'x-message-ttl'             => $delay * 1000,
+                ], (array)$this->configQueue['arguments']);
+            
             $this->channel->queue_declare(
                 $name,
                 $this->configQueue['passive'],
                 $this->configQueue['durable'],
                 $this->configQueue['exclusive'],
                 $this->configQueue['auto_delete'],
                 false,
-                new AMQPTable([
-                    'x-dead-letter-exchange'    => $destinationExchange,
-                    'x-dead-letter-routing-key' => $destination,
-                    'x-message-ttl'             => $delay * 1000,
-                ])
+                new AMQPTable($queueArguments)
             );
         }
 

tests/RabbitMQConnectorTest.php

@@ -25,6 +25,7 @@ public function test_connect()
                 'durable'     => true,
                 'exclusive'   => false,
                 'auto_delete' => false,
+                'arguments'   => false,
             ],
             'exchange_params' => [
                 'name'        => null,

tests/RabbitMQQueueTest.php

@@ -31,6 +31,7 @@ public function setUp()
                 'durable'     => true,
                 'exclusive'   => false,
                 'auto_delete' => false,
+                'arguments'   => false,
             ],
             'exchange_params' => [
                 'name'        => 'exchange_name',
@@ -80,7 +81,9 @@ public function test_push()
             $this->config['queue_params']['passive'],
             $this->config['queue_params']['durable'],
             $this->config['queue_params']['exclusive'],
-            $this->config['queue_params']['auto_delete']
+            $this->config['queue_params']['auto_delete'],
+            false,
+            $this->config['queue_params']['arguments']
         )->once();
 
         $this->channel->shouldReceive('queue_bind')->with(
@@ -150,7 +153,9 @@ public function test_pop()
             $this->config['queue_params']['passive'],
             $this->config['queue_params']['durable'],
             $this->config['queue_params']['exclusive'],
-            $this->config['queue_params']['auto_delete']
+            $this->config['queue_params']['auto_delete'],
+            false,
+            $this->config['queue_params']['arguments']
         )->once();
 
         $this->channel->shouldReceive('queue_bind')->with(