implemented replay handling

adrai · Mar 27, 2012 · 1c9b437 · 1c9b437
1 parent ce4c76f
commit 1c9b437
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/adapters/pub.js b/lib/adapters/pub.js
@@ -47,7 +47,7 @@ var PubAdapter = function(hub, callback) {
         if (!this.hub.options.channel){
             this.hub.connection.exchange('amq.fanout', {passive: true}, handle);
         } else {
-            this.hub.connection.exchange(this.hub.options.channel, {type: 'fanout'}, handle);
+            this.hub.connection.exchange(this.hub.options.channel, {type: 'fanout', autoDelete: true}, handle);
         }
 
     };

diff --git a/lib/adapters/sub.js b/lib/adapters/sub.js
@@ -47,7 +47,7 @@ var SubAdapter = function(hub, callback) {
         if (!this.hub.options.channel){
             this.hub.connection.exchange('amq.fanout', {passive: true}, handle);
         } else {
-            this.hub.connection.exchange(this.hub.options.channel, {type: 'fanout'}, handle);
+            this.hub.connection.exchange(this.hub.options.channel, {type: 'fanout', autoDelete: true}, handle);
         }
 
     };