()
| 153 | } |
| 154 | |
| 155 | public createClient(): AmqpConnectionManager { |
| 156 | const socketOptions = this.getOptionsProp(this.options, 'socketOptions'); |
| 157 | const urls = this.getOptionsProp(this.options, 'urls') || [RQM_DEFAULT_URL]; |
| 158 | return rmqPackage.connect(urls, socketOptions); |
| 159 | } |
| 160 | |
| 161 | public mergeDisconnectEvent<T = any>( |
| 162 | instance: any, |
no test coverage detected