Skip to content
Browse files

add fanout exchanges

  • Loading branch information...
1 parent 05c24f3 commit 6c6df1b9e9ff461f438356e4551cbe9f4f92b1d3 @mhat committed Jul 19, 2011
Showing with 4 additions and 0 deletions.
  1. +4 −0 lib/carrot.rb
View
4 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

0 comments on commit 6c6df1b

Please sign in to comment.
Something went wrong with that request. Please try again.