From d38d398b610a63dc65e6dd231d18716191b2f856 Mon Sep 17 00:00:00 2001 From: Kines Date: Mon, 29 Sep 2014 12:29:48 +0300 Subject: [PATCH 1/2] Pass autoDelete option to SubSocket --- lib/sockets.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/sockets.js b/lib/sockets.js index b793962..dc17cf3 100644 --- a/lib/sockets.js +++ b/lib/sockets.js @@ -238,7 +238,7 @@ SubSocket.prototype.connect = function(source, topic, callback) { var ch = this.ch, queue = this.queue, self = this; ch.assertExchange(source, this.options.routing || 'fanout', - {durable: false, autoDelete: false}) + {durable: false, autoDelete: this.options.autoDelete || false}) .then(function(ok) { return ch.bindQueue(queue, source, topic); }) From 8fd906f5d319a97d59d35e662aa5335efef45115 Mon Sep 17 00:00:00 2001 From: Kines Date: Tue, 30 Sep 2014 10:05:05 +0300 Subject: [PATCH 2/2] added autoDelete flag passing to PubSocket --- lib/sockets.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/sockets.js b/lib/sockets.js index dc17cf3..37db48b 100644 --- a/lib/sockets.js +++ b/lib/sockets.js @@ -179,7 +179,7 @@ PubSocket.prototype.connect = function(destination, callback) { var self = this, ch = this.ch; ch.assertExchange(destination, this.options.routing || 'fanout', - {durable: false, autoDelete: false}) + {durable: false, autoDelete: this.options.autoDelete || false}) .then(function(ok) { self.pubs.push(destination); }).then(callback);