Fanouts #8

Merged
merged 1 commit into from Oct 20, 2011
Jump to file or symbol
Failed to load files and symbols.
+4 −0
Split
View
@@ -61,6 +61,10 @@ def headers(name = 'amq.match', opts = {})
exchanges[name] ||= AMQP::Exchange.new(self, :headers, name, opts)
end
+ def fanout(name = 'amq.fanout', opts = {})
+ exchanges[name] ||= AMQP::Exchange.new(self, :fanout, name, opts)
+ end
+
def exchanges
@exchanges ||= {}
end