lib/carrot.rb in carrot-1.1.0 vs lib/carrot.rb in carrot-1.2.0

- old
+ new

@@ -59,9 +59,13 @@ 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 private