Module: RosettaQueue::Gateway::Fanout

Included in:
EventedExchange::FanoutExchange, SynchExchange::FanoutExchange
Defined in:
lib/rosetta_queue/adapters/amqp.rb

Instance Method Summary collapse

Instance Method Details

#fanout_name_for(destination) ⇒ Object

Raises:



5
6
7
8
9
 
# File 'lib/rosetta_queue/adapters/amqp.rb', line 5

def fanout_name_for(destination)
  fanout_name = destination.gsub(/(topic|fanout)\/(.*)/, '\2')
  raise AdapterException, "Unable to discover fanout exchange. Cannot bind queue to exchange!" unless fanout_name
  fanout_name
end