()
| 167 | } |
| 168 | |
| 169 | public createClient<T = any>(): T { |
| 170 | const socketOptions = this.getOptionsProp(this.options, 'socketOptions'); |
| 171 | return rmqPackage.connect(this.urls, { |
| 172 | connectionOptions: socketOptions?.connectionOptions, |
| 173 | heartbeatIntervalInSeconds: socketOptions?.heartbeatIntervalInSeconds, |
| 174 | reconnectTimeInSeconds: socketOptions?.reconnectTimeInSeconds, |
| 175 | }); |
| 176 | } |
| 177 | |
| 178 | private registerConnectListener() { |
| 179 | this.server!.on(RmqEventsMap.CONNECT, (err: any) => { |