Added arguments for declaring an exchange

Author: elvenpath

config/rabbitmq.php

@@ -44,6 +44,7 @@
             'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false),
             'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true),
             'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),
+            'arguments' => env('RABBITMQ_EXCHANGE_ARGUMENTS'),
         ],
 
         'queue' => [
@@ -71,9 +72,7 @@
             'exclusive' => env('RABBITMQ_QUEUE_EXCLUSIVE', false),
             'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false),
             'arguments' => env('RABBITMQ_QUEUE_ARGUMENTS'),
-
         ],
-
     ],
 
     /*

src/Queue/RabbitMQQueue.php

@@ -34,9 +34,12 @@ public function __construct(AmqpContext $context, array $config)
         $this->context = $context;
 
         $this->queueOptions = $config['options']['queue'];
-        $this->queueOptions['arguments'] = isset($this->queueOptions['arguments']) ? json_decode($this->queueOptions['arguments'], true) : [];
+        $this->queueOptions['arguments'] = isset($this->queueOptions['arguments']) ?
+            json_decode($this->queueOptions['arguments'], true) : [];
 
         $this->exchangeOptions = $config['options']['exchange'];
+        $this->exchangeOptions['arguments'] = isset($this->exchangeOptions['arguments']) ?
+            json_decode($this->exchangeOptions['arguments'], true) : [];
 
         $this->sleepOnError = $config['sleep_on_error'] ?? 5;
     }
@@ -176,6 +179,7 @@ private function declareEverything(string $queueName = null): array
 
         $topic = $this->context->createTopic($exchangeName);
         $topic->setType($this->exchangeOptions['type']);
+        $topic->setArguments($this->exchangeOptions['arguments']);
         if ($this->exchangeOptions['passive']) {
             $topic->addFlag(AmqpTopic::FLAG_PASSIVE);
         }