Merge pull request #21 from signalive/hotfix

Hotfix
signalive · Dec 15, 2016 · c3183cf · c3183cf
2 parents 6454e53 + 37caab9
commit c3183cf
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "microservice-kit",
-  "version": "0.3.11",
+  "version": "0.3.12",
   "description": "",
   "main": "src/index.js",
   "scripts": {
@@ -9,7 +9,7 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "amqplib": "^0.4.0",
+    "amqplib": "0.5.1",
     "async": "^1.5.0",
     "async-q": "^0.2.2",
     "chance": "^0.8.0",

diff --git a/src/amqpkit.js b/src/amqpkit.js
@@ -88,6 +88,7 @@ class AmqpKit {
     bindEvents() {
         this.connection.on('close', () => {
             debug('connection closed');
+            ShutdownKit.gracefulShutdown();
         });
 
         this.connection.on('error', (err) => {

diff --git a/src/shutdownkit.js b/src/shutdownkit.js
@@ -76,9 +76,7 @@ class ShutdownKit {
             else
                 this.log_('info', 'All jobs done, quiting...');
 
-            this.log_('info', 'Bye!', () => {
-                this.exit_();
-            });
+            this.exit_();
         });
     }
 
@@ -87,6 +85,7 @@ class ShutdownKit {
      * Exists current process.
      */
     exit_() {
+        this.log_('info', 'Bye!');
         process.exit();
     }