add fanout exchanges

famoseagle · Jul 20, 2011 · 6c6df1b · 6c6df1b
1 parent 05c24f3
commit 6c6df1b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/carrot.rb b/lib/carrot.rb
@@ -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