removeAllSessions() to clean up connection. (#33)

* removeAllSessions() to clean up connection.
amqp · Mar 18, 2019 · aa58f32 · aa58f32
1 parent fc54de2
commit aa58f32
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 4 deletions.
diff --git a/lib/connection.ts b/lib/connection.ts
@@ -376,6 +376,15 @@ export class Connection extends Entity {
     return result;
   }
 
+  /**
+   * Remove all the sessions from the internal map.
+   */
+  removeAllSessions(): void {
+    if (this._connection) {
+      this._connection.remove_all_sessions();
+    }
+  }
+
   /**
    * Determines whether the remote end of the connection is open.
    * @returns {boolean} result `true` - is open; `false` otherwise.

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -7,7 +7,7 @@
   "types": "./typings/lib/index.d.ts",
   "dependencies": {
     "debug": "^3.1.0",
-    "rhea": "^1.0.0",
+    "rhea": "^1.0.2",
     "tslib": "^1.9.3"
   },
   "keywords": [