amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(microservices): add type for rmq connection options

Browse Source 
change socketOptions.connectionOptions type from any to copied amqp-manager's AmqpConnectionOptions

Closes https://github.com/nestjs/nest/issues/13071
This commit is contained in:
Deniks
2024-01-27 16:12:38 +00:00
parent 95e8b94435
commit 4008cc23c9
3 changed files with 30 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
packages/microservices/server/server-rmq.ts
View File

@@ -31,7 +31,7 @@ import {
import { RmqRecordSerializer } from '../serializers/rmq-record.serializer';
import { Server } from './server';
let rqmPackage: any = {};
let rmqPackage: any = {};
const INFINITE_CONNECTION_ATTEMPTS = -1;
@@ -67,7 +67,7 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
this.getOptionsProp(this.options, 'noAssert') || RQM_DEFAULT_NO_ASSERT;
this.loadPackage('amqplib', ServerRMQ.name, () => require('amqplib'));
rqmPackage = this.loadPackage(
rmqPackage = this.loadPackage(
'amqp-connection-manager',
ServerRMQ.name,
() => require('amqp-connection-manager'),
@@ -136,7 +136,7 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
public createClient<T = any>(): T {
const socketOptions = this.getOptionsProp(this.options, 'socketOptions');
return rqmPackage.connect(this.urls, {
return rmqPackage.connect(this.urls, {
connectionOptions: socketOptions,
heartbeatIntervalInSeconds: socketOptions?.heartbeatIntervalInSeconds,
reconnectTimeInSeconds: socketOptions?.reconnectTimeInSeconds,