From 81cd0ac324e5f9ad648640f7738b6c7424d70989 Mon Sep 17 00:00:00 2001
From: Ilya Bushin <big@mail.ru>
Date: Mon, 9 Mar 2020 17:41:12 +0300
Subject: [PATCH] feat(rabbitmq): add correlationId to request

---
 packages/rabbitmq/src/amqp/connection.ts     | 2 +-
 packages/rabbitmq/src/rabbitmq.interfaces.ts | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/packages/rabbitmq/src/amqp/connection.ts b/packages/rabbitmq/src/amqp/connection.ts
index 1e91fcc14..30e80aad3 100644
--- a/packages/rabbitmq/src/amqp/connection.ts
+++ b/packages/rabbitmq/src/amqp/connection.ts
@@ -182,7 +182,7 @@ export class AmqpConnection {
   public async request<T extends {}>(
     requestOptions: RequestOptions
   ): Promise<T> {
-    const correlationId = uuid.v4();
+    const correlationId = requestOptions.correlationId || uuid.v4();
     const timeout = requestOptions.timeout || this.config.defaultRpcTimeout;
     const payload = requestOptions.payload || {};
 
diff --git a/packages/rabbitmq/src/rabbitmq.interfaces.ts b/packages/rabbitmq/src/rabbitmq.interfaces.ts
index 1a6bce081..0b53bd879 100644
--- a/packages/rabbitmq/src/rabbitmq.interfaces.ts
+++ b/packages/rabbitmq/src/rabbitmq.interfaces.ts
@@ -15,6 +15,7 @@ export interface MessageOptions {
 export interface RequestOptions {
   exchange: string;
   routingKey: string;
+  correlationId?: string;
   timeout?: number;
   payload?: any;
 }