Merge pull request #17 from kata-ai/feature/reconnect-tested

works

Author: goFrendiAsgard

lib/service_amqp.js

@@ -12,6 +12,8 @@ module.exports = class Amqp extends Component.mixin(AsyncEmitter) {
         this.logger = logger;
         this._connection;
         this._initializing = false;
+        this.serviceSub = null;
+        this.serviceSubQueue = null;
     }
 
     initialize() {
@@ -57,6 +59,8 @@ module.exports = class Amqp extends Component.mixin(AsyncEmitter) {
             this.logger.warn("Failed to connect to rmq.", e);
             yield sleep(3000);
             this.logger.info("Attempting to reconnect to rmq.");
+            this.serviceSub._initializing = false;
+            this.serviceSubQueue._initializing = false;
 
             yield this.doConnect();
         }

lib/service_sub_queue_rabbit.js

@@ -13,6 +13,7 @@ class ServiceSubRabbit extends ServiceSubQueue {
         this.logger = logger;
         this.injector = injector;
         this.amqp = amqp;
+        this.amqp.serviceSubQueue = this;
 
         this.SERVICE_NAME = config.default("name", "unnamed-service");
         this.VERSION = pack.version;

lib/service_sub_rabbit.js

@@ -14,6 +14,7 @@ class ServiceSubRabbit extends ServiceSub {
         this.logger = logger;
         this.injector = injector;
         this.amqp = amqp;
+        this.amqp.serviceSub = this;
         this.servicePubRabbit = servicePubRabbit;
 
         this.SERVICE_NAME = config.default("name", "unnamed-service");