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 {