module ActivePubsub

# File lib/active_pubsub.rb, line 24
def self.configure
  yield(configuration)

  ::ActiveSupport.run_load_hooks(:active_pubsub, self)
end

# File lib/active_pubsub.rb, line 30
def self.disable_publisher!
  configuration.disable_publisher = true
end

# File lib/active_pubsub.rb, line 34
def self.load_subscribers
  ::Dir.glob(::Rails.root.join('app', 'subscribers', "*.rb")).each{ |file| load file }
end

# File lib/active_pubsub.rb, line 38
def self.logger
  configuration.logger
end

# File lib/active_pubsub.rb, line 42
def self.logger?
  configuration.logger.present?
end

# File lib/active_pubsub.rb, line 46
def self.publisher
  ::Celluloid::Actor[:rabbit_publisher]
end

# File lib/active_pubsub.rb, line 50
def self.publisher_disabled?
  configuration.publisher_disabled
end

# File lib/active_pubsub.rb, line 54
def self.start_publisher
  ::ActivePubsub::Publisher.start unless ::ActivePubsub::Publisher.started?
end

# File lib/active_pubsub.rb, line 58
def self.start_subscribers
  ::ActivePubsub::Subscriber.subclasses.each do |subscriber|
    next if subscriber.started?

    ::ActivePubsub.logger.info("Starting #{subscriber.name}")

    subscriber.bind_subscriptions!
    subscriber.print_subscriptions!
  end
end

# File lib/active_pubsub.rb, line 69
def self.symbolize_routing_key(routing_key)
  :"#{routing_key.split('.').join('_')}"
end