diff --git a/lib/sockets.js b/lib/sockets.js
index b793962..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);
@@ -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);
     })