feat(rabbitmq): add correlationId to request

golevelup · Mar 26, 2020 · 81cd0ac · 81cd0ac
1 parent c20ba1b
commit 81cd0ac
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git 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
@@ -15,6 +15,7 @@ export interface MessageOptions {
 export interface RequestOptions {
   exchange: string;
   routingKey: string;
+  correlationId?: string;
   timeout?: number;
   payload?: any;
 }