feat(microservices): Add exchange arguments to RabbitMQ

Author: Igor Gaponov

packages/microservices/client/client-rmq.ts

@@ -229,6 +229,7 @@ export class ClientRMQ extends ClientProxy<RmqEvents, RmqStatus> {
       );
       await channel.assertExchange(exchange, exchangeType, {
         durable: true,
+        arguments: this.getOptionsProp(this.options, 'exchangeArguments', {}),
       });
     }
 

packages/microservices/interfaces/microservice-configuration.interface.ts

@@ -287,6 +287,10 @@ export interface RmqOptions {
      * @default 'topic'
      */
     exchangeType?: 'direct' | 'fanout' | 'topic' | 'headers';
+    /**
+     * Exchange arguments
+     */
+    exchangeArguments?: Record<string, string>;
     /**
      * Additional routing key for the topic exchange.
      */

packages/microservices/server/server-rmq.ts

@@ -217,6 +217,7 @@ export class ServerRMQ extends Server<RmqEvents, RmqStatus> {
       );
       await channel.assertExchange(exchange, exchangeType, {
         durable: true,
+        arguments: this.getOptionsProp(this.options, 'exchangeArguments', {}),
       });
 
       if (this.options.routingKey) {