Added options for conditional queue delete

moscajs · Feb 15, 2018 · 91a6bd4 · 91a6bd4
1 parent e6f696a
commit 91a6bd4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/amqplib_ascoltatore.js b/lib/amqplib_ascoltatore.js
@@ -199,7 +199,7 @@ AMQPLibAscoltatore.prototype.close = function close(done) {
     };
 
     this._client_conn.on("close", doClose);
-    this._channel.deleteQueue(this._queue);
+    this._channel.deleteQueue(this._queue, { "ifUnused": true, "ifEmpty": true });
     this._channel.close();
 
     this._client_conn.close();