fix - [RabbitMQ Microservice] "PRECONDITION_FAILED - reply consumer already set" nestjs#3138

Author: tsergey-itrex

packages/microservices/client/client-rmq.ts

@@ -82,6 +82,12 @@ export class ClientRMQ extends ClientProxy {
         share(),
       )
       .toPromise();
+
+    this.client.on(DISCONNECT_EVENT, (err)=> {
+      this.close();
+      this.client = null;
+    });
+
     return this.connection;
   }
 

packages/microservices/server/server-rmq.ts

@@ -69,6 +69,9 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
   public async start(callback?: () => void) {
     this.server = this.createClient();
     this.server.on(CONNECT_EVENT, (_: any) => {
+      if (this.channel) {
+        return;
+      }
       this.channel = this.server.createChannel({
         json: false,
         setup: (channel: any) => this.setupChannel(channel, callback),