fix(microservices): pass rmq connection options correctly to amqp-connection-manager

This commit is contained in:
JonathanMbt
2024-04-13 16:23:45 +02:00
committed by GitHub
parent 6f119a7fdd
commit 3424843c81
2 changed files with 2 additions and 2 deletions

View File

@@ -140,7 +140,7 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
public createClient<T = any>(): T {
const socketOptions = this.getOptionsProp(this.options, 'socketOptions');
return rmqPackage.connect(this.urls, {
connectionOptions: socketOptions,
connectionOptions: socketOptions?.connectionOptions,
heartbeatIntervalInSeconds: socketOptions?.heartbeatIntervalInSeconds,
reconnectTimeInSeconds: socketOptions?.reconnectTimeInSeconds,
});