feat: handle close connection

Author: Sebastian-Iwanczyszyn

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjstools/messaging-rabbitmq-extension",
-  "version": "3.0.5",
+  "version": "3.1.0",
   "description": "Extension to handle messages and dispatch them over AMQP protocol",
   "author": "Sebastian Iwanczyszyn",
   "private": false,

src/channel/amqp.channel.ts

@@ -19,6 +19,10 @@ export class AmqpChannel extends Channel<ExtensionAmqpChannelConfig> {
     this.connection = undefined;
 
     this.connection = await amqp.connect(this.config.connectionUri);
+    this.connection.on('close', (err: any) => {
+      console.error('AMQP Connection error:', err);
+      process.exit(0);
+    });
   }
 
   async onChannelDestroy(): Promise<void> {