Merge pull request #7345 from alexreal1314/bugfix/amqpConnectionMgr

fix(microservices): fixed bug that socketOptions object not passed to…
nestjs · Jun 30, 2021 · d31b207 · d31b207
2 parents 34c8453 + 674dd56
commit d31b207
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/packages/microservices/server/server-rmq.ts b/packages/microservices/server/server-rmq.ts
@@ -99,7 +99,11 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
 
   public createClient<T = any>(): T {
     const socketOptions = this.getOptionsProp(this.options, 'socketOptions');
-    return rqmPackage.connect(this.urls, { connectionOptions: socketOptions });
+    return rqmPackage.connect(this.urls, { 
+        connectionOptions: socketOptions,
+        heartbeatIntervalInSeconds: socketOptions?.heartbeatIntervalInSeconds,
+        reconnectTimeInSeconds: socketOptions?.reconnectTimeInSeconds
+    });
   }
 
   public async setupChannel(channel: any, callback: Function) {