From d0a2192b430dc4ae8151aedc79d400d49aa1fb02 Mon Sep 17 00:00:00 2001
From: Rodrigo <monstawoodwow@gmail.com>
Date: Sun, 23 Jan 2022 00:46:07 +0000
Subject: [PATCH] feat(rabbitmq): allow setting custom message headers (#374)

fixes #372
---
 packages/rabbitmq/src/amqp/connection.ts     | 5 +++--
 packages/rabbitmq/src/rabbitmq.interfaces.ts | 1 +
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/packages/rabbitmq/src/amqp/connection.ts b/packages/rabbitmq/src/amqp/connection.ts
index a906def7b..8fbbc820c 100644
--- 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
index 072ccfbd8..ccf6167d4 100644
--- 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 {