feature(microservices): update acceptable types in RabbitMq urls

This commit is contained in:
ccappai
2020-10-26 11:38:20 +01:00
parent 513080d8f7
commit b8c479ebe5
3 changed files with 14 additions and 2 deletions

View File

@@ -17,6 +17,7 @@ import {
} from '../constants';
import { ReadPacket, RmqOptions, WritePacket } from '../interfaces';
import { ClientProxy } from './client-proxy';
import {RmqUrl} from "../external/rmq-url.interface";
let rqmPackage: any = {};
@@ -27,7 +28,7 @@ export class ClientRMQ extends ClientProxy {
protected connection: Promise<any>;
protected client: any = null;
protected channel: any = null;
protected urls: string[];
protected urls: string[] | RmqUrl[];
protected queue: string;
protected queueOptions: any;
protected responseEmitter: EventEmitter;