Emit error when reconnection failed

Author: antoinegomez

src/module/rabbitmq.extension.ts

@@ -78,6 +78,10 @@ export class RabbitMQExt implements OnExtensionLoad, OnModuleInstantiated, OnShu
                 .do(() => this.onModuleInstantiated(module, connection))
                 .subscribe(() => {}, err => {
                     errorHandler(err);
+                    const connectionError: any = new Error('@hapiness/rabbitmq Connection error');
+                    connectionError.source = err;
+                    connectionError.key = 'HAPINESS_RABBITMQ_CONNECTION_ERROR';
+                    connection.emit('error', connectionError);
                 });
         });