Commit 60fdc4a8 authored by Merzough Münker's avatar Merzough Münker
Browse files

fix: use unique transport id

parent a71d1c4c

packages/nest/rabbitmq/src/lib/server-rmq.ts

+3 −4
Original line number Diff line number Diff line
@@ -36,11 +36,10 @@ let rmqPackage: any = {}; 


const INFINITE_CONNECTION_ATTEMPTS = -1;



/**

 * @publicApi

 */

export const TRANSPORT_ID = Symbol('RxAP_RMQ');



export class ServerRMQ extends Server implements CustomTransportStrategy {

  public readonly transportId = Transport.RMQ;

  public readonly transportId = TRANSPORT_ID;



  protected server: any = null;

  protected channel: any = null;