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