PUB/SUB exchange don't have to be durable

squaremo · squaremo · commit 08420ab5d690 · 2014-03-10T03:23:05.000Z
If you assume connect/subscribe will be called again on a new socket.
diff --git a/lib/sockets.js b/lib/sockets.js
@@ -161,7 +161,7 @@ PubSocket.prototype.connect = function(destination, callback) {
   var self = this, ch = this.ch;
   ch.assertExchange(destination,
                     this.options.routing || 'fanout',
-                    {durable: this.options.persistent,
+                    {durable: false,
                      autoDelete: true})
     .then(function(ok) {
       self.pubs.push(destination);
@@ -220,8 +220,7 @@ SubSocket.prototype.connect = function(source, callback) {
   var ch = this.ch, queue = this.queue, self = this;
   ch.assertExchange(source,
                     this.options.routing || 'fanout',
-                    {durable: this.options.persistent,
-                     autoDelete: true})
+                    {autoDelete: true})
     .then(function(ok) {
       self.subs.push(source);
       self.patterns.forEach(function(pat) {
