feat: add option for arguments when binding queue to an exchange (#346)

fixes #343
golevelup · Dec 17, 2021 · c561e73 · c561e73
1 parent d47ea96
commit c561e73
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/packages/rabbitmq/src/amqp/connection.ts b/packages/rabbitmq/src/amqp/connection.ts
@@ -433,13 +433,23 @@ export class AmqpConnection {
       actualQueue = queue;
     }
 
+    let bindQueueArguments: any;
+    if (subscriptionOptions.queueOptions) {
+      bindQueueArguments = subscriptionOptions.queueOptions.bindQueueArguments;
+    }
+
     const routingKeys = Array.isArray(routingKey) ? routingKey : [routingKey];
 
     if (exchange && routingKeys) {
       await Promise.all(
         routingKeys.map((routingKey) => {
           if (routingKey != null) {
-            channel.bindQueue(actualQueue as string, exchange, routingKey);
+            channel.bindQueue(
+              actualQueue as string,
+              exchange,
+              routingKey,
+              bindQueueArguments
+            );
           }
         })
       );

diff --git a/packages/rabbitmq/src/rabbitmq.interfaces.ts b/packages/rabbitmq/src/rabbitmq.interfaces.ts
@@ -35,6 +35,7 @@ export interface QueueOptions {
   deadLetterRoutingKey?: string;
   maxLength?: number;
   maxPriority?: number;
+  bindQueueArguments?: any;
 }
 
 export interface MessageHandlerOptions {