feat(rabbitmq): allow setting custom message headers (#374)

fixes #372
golevelup · Jan 23, 2022 · d0a2192 · d0a2192
1 parent bc49fbc
commit d0a2192
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/packages/rabbitmq/src/amqp/connection.ts b/packages/rabbitmq/src/amqp/connection.ts
@@ -263,6 +263,7 @@ export class AmqpConnection {
       {
         replyTo: DIRECT_REPLY_QUEUE,
         correlationId,
+        headers: requestOptions.headers,
       }
     );
 
@@ -384,9 +385,9 @@ export class AmqpConnection {
           return;
         }
 
-        const { replyTo, correlationId } = msg.properties;
+        const { replyTo, correlationId, headers } = msg.properties;
         if (replyTo) {
-          await this.publish('', replyTo, response, { correlationId });
+          await this.publish('', replyTo, response, { correlationId, headers });
         }
         channel.ack(msg);
       } catch (e) {

diff --git a/packages/rabbitmq/src/rabbitmq.interfaces.ts b/packages/rabbitmq/src/rabbitmq.interfaces.ts
@@ -23,6 +23,7 @@ export interface RequestOptions {
   correlationId?: string;
   timeout?: number;
   payload?: any;
+  headers?: any;
 }
 
 export interface QueueOptions {