revert changes to 3b03a37

Author: goFrendiAsgard

README.md

@@ -203,9 +203,6 @@ export RABBIT_HOST=0.0.0.0
 export RABBIT_PORT=5672
 export RABBIT_USERNAME=root
 export RABBIT_PASSWORD=toor
-# these commands are for reconnecting test
-export START_RABBIT_COMMAND="docker start rabbitmq"
-export STOP_RABBIT_COMMAND="docker stop rabbitmq"
 ```
 
 and perform:

index.js

@@ -13,6 +13,8 @@ module.exports = function () {
             container.register("servicePubQueueRabbit", require("./lib/service_pub_queue_rabbit"));
             container.register("serviceSubQueueRabbit", require("./lib/service_sub_queue_rabbit"));
             container.alias("serviceSubQueue", "serviceSubQueueRabbit");
+
+            container.register("amqp", require("./lib/service_amqp"));
         },
         *onInit(container) {
             let service = yield container.resolve("service");
@@ -28,4 +30,4 @@ module.exports = function () {
             service.addModule("sub-queue-rabbit", serviceSubQueueRabbit);
         }
     };
-};
+};

labs/amqplib-reconnect-test.js

@@ -3,11 +3,9 @@
 const { Component, AsyncEmitter } = require("merapi");
 const pack = require("../package");
 
-const Rabbit = require("./Rabbit");
-
 class ServicePubQueueRabbit extends Component.mixin(AsyncEmitter) {
 
-    constructor(config, logger, injector, servicePubQueue) {
+    constructor(config, logger, injector, amqp, servicePubQueue) {
         super();
 
         this.config = config;
@@ -97,4 +95,4 @@ class ServicePubQueueRabbit extends Component.mixin(AsyncEmitter) {
     *unmount() { }
 }
 
-module.exports = ServicePubQueueRabbit;
+module.exports = ServicePubQueueRabbit;