fix: check isShuttingDown before doConnect (#23)

Author: rizkifuad

lib/service_amqp.js

@@ -12,6 +12,7 @@ module.exports = class Amqp extends Component.mixin(AsyncEmitter) {
     this.logger = logger;
     this._connection;
     this._initializing = false;
+    this._isShuttingDown = false;
     this.serviceSub = null;
     this.serviceSubQueue = null;
     this.signals = ["SIGINT", "SIGTERM", "SIGQUIT"];
@@ -27,6 +28,7 @@ module.exports = class Amqp extends Component.mixin(AsyncEmitter) {
 
   *doConnect() {
     if (this._initializing) return;
+    if (this._isShuttingDown) return;
     this._initializing = true;
     let {
       secure,
@@ -82,6 +84,7 @@ module.exports = class Amqp extends Component.mixin(AsyncEmitter) {
 
   *stop() {
     try {
+      this._isShuttingDown = true;
       this.logger.info("Shutting down rabbitmq plugin...");
       this._connection.close();
     } catch (e) {