module DramaQueen

This is the singleton that maintains the list of active exchanges.

Constants

VERSION

Public Class Methods

exchange_for(routing_key) click to toggle source

Finds the DramaQueen::Exchange for the given routing_key.

@param [Object] routing_key @return [DramaQueen::Exchange]

# File lib/drama_queen.rb, line 19
def self.exchange_for(routing_key)
  exchanges.find do |exchange|
    exchange.routing_key == routing_key
  end
end

exchanges() click to toggle source

The list of all exchanges that DramaQueen knows about. This is updated by DramaQueen::Consumers as they subscribe to topics.

@return [Array<DramaQueen::Exchange>]

# File lib/drama_queen.rb, line 11
def self.exchanges
  @exchanges ||= Array.new
end

routes_to?(routing_key) click to toggle source

@param [Object] routing_key @return [Boolean]

# File lib/drama_queen.rb, line 27
def self.routes_to?(routing_key)
  !!exchange_for(routing_key)
end

unsubscribe_all() click to toggle source

Removes all exchanges from the exchanges list.

@return [Array]

# File lib/drama_queen.rb, line 34
def self.unsubscribe_all
  @exchanges = Array.new
end