Merge pull request #41 from hapinessjs/next

Next

Author: fauvillej

README.md

@@ -453,6 +453,8 @@ To set up your development environment:
 [Back to top](#table-of-contents)
 
 ## Change History
+* v1.5.1 (2018-09-24)
+    * Fix reconnection error: use once instad of on and rebind event correctly
 * v1.5.0 (2018-08-24)
     * Add possibility to provide a custom MessageRouter
 * v1.4.3 (2018-08-20)

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@hapiness/rabbitmq",
-  "version": "1.5.0",
+  "version": "1.5.1",
   "description": "Hapiness module for rabbitmq",
   "main": "commonjs/index.js",
   "types": "index.d.ts",

package.json

@@ -71,12 +71,17 @@ export class RabbitMQExt implements OnExtensionLoad, OnModuleInstantiated, OnShu
         debug('bootstrapping module: asserting exchanges, queues, binds, messages routing');
 
         // Try to reconnect and launch bootstrap when we have an error
-        connection.on('error', () => {
+        connection.once('error', () => {
+            debug('connection.once#error: try to reconnect');
             connection
                 .connect()
-                .flatMap(() => RegisterAnnotations.bootstrap(module, connection, RabbitMQExt.MessageRouter))
+                .do(() => this.onModuleInstantiated(module, connection))
                 .subscribe(() => {}, err => {
                     errorHandler(err);
+                    const connectionError: any = new Error('Connection error');
+                    connectionError.source = err;
+                    connectionError.key = 'HAPINESS_RABBITMQ_CONNECTION_ERROR';
+                    connection.emit('error', connectionError);
                 });
         });
 
@@ -97,5 +102,3 @@ export class RabbitMQExt implements OnExtensionLoad, OnModuleInstantiated, OnShu
         };
     }
 }
-
-