Pass socketOptions to connect method

Author: Upperfoot

packages/microservices/client/client-rmq.ts

@@ -12,6 +12,7 @@ import {
   RQM_DEFAULT_PREFETCH_COUNT,
   RQM_DEFAULT_QUEUE,
   RQM_DEFAULT_QUEUE_OPTIONS,
+  RQM_DEFAULT_SOCKET_OPTIONS,
   RQM_DEFAULT_URL,
 } from './../constants';
 import { WritePacket } from './../interfaces';
@@ -29,6 +30,7 @@ export class ClientRMQ extends ClientProxy {
   protected prefetchCount: number;
   protected isGlobalPrefetchCount: boolean;
   protected queueOptions: any;
+  protected socketOptions: any;
   protected replyQueue: string;
   protected responseEmitter: EventEmitter;
 
@@ -49,6 +51,9 @@ export class ClientRMQ extends ClientProxy {
     this.queueOptions =
       this.getOptionsProp<RmqOptions>(this.options, 'queueOptions') ||
       RQM_DEFAULT_QUEUE_OPTIONS;
+    this.socketOptions =
+      this.getOptionsProp<RmqOptions>(this.options, 'socketOptions') ||
+      RQM_DEFAULT_SOCKET_OPTIONS;
 
     loadPackage('amqplib', ClientRMQ.name);
     rqmPackage = loadPackage('amqp-connection-manager', ClientRMQ.name);
@@ -93,7 +98,7 @@ export class ClientRMQ extends ClientProxy {
   }
 
   public createClient<T = any>(): T {
-    return rqmPackage.connect(this.urls) as T;
+    return rqmPackage.connect(this.urls, this.socketOptions) as T;
   }
 
   public mergeDisconnectEvent<T = any>(