feat(adapter/amqp): not execute body of disconnect method when state …

…is not connected

src/AMQPAdapter.js

@@ -256,24 +256,29 @@ class AMQPAdapter {
   }
 
   async disconnect({ gracefulStopTimeout = 10000 }: { gracefulStopTimeout?: number } = {}) {
+    if (!['connecting', 'connected', 'blocked'].includes(this._state)) {
+      return;
+    }
+
     this._state = 'disconnecting';
 
-    // @todo in wait end time reject with requeue all messages or unsubscribe
-    // but how we can ack is this situation?
-    if (gracefulStopTimeout > 0) {
-      try {
-        await this._waitEndHandlers(gracefulStopTimeout);
-      } catch (err) {
-        this._errorHandler(
-          EError.wrap(err, {
-            gracefulStopTimeout,
-            subMessage: 'Error at graceful disconnect',
-          }),
-        );
-      }
+    if (gracefulStopTimeout <= 0) {
+      await this._connection.close();
+      return;
     }
 
-    await this._connection.close();
+    try {
+      await this._waitEndHandlers(gracefulStopTimeout);
+    } catch (err) {
+      this._errorHandler(
+        EError.wrap(err, {
+          gracefulStopTimeout,
+          subMessage: 'Error at graceful disconnect',
+        }),
+      );
+    } finally {
+      await this._connection.close();
+    }
   }
 
   async _waitEndHandlers(gracefulStopTimeout: number) {