module ActivePubsub

Constants

VERSION

Attributes

config[RW]
configuration[RW]

Public Class Methods

configure() { |configuration| ... } click to toggle source
# File lib/active_pubsub.rb, line 24
def self.configure
  yield(configuration)

  ::ActiveSupport.run_load_hooks(:active_pubsub, self)
end
disable_publisher!() click to toggle source
# File lib/active_pubsub.rb, line 30
def self.disable_publisher!
  configuration.disable_publisher = true
end
load_subscribers() click to toggle source
# File lib/active_pubsub.rb, line 34
def self.load_subscribers
  ::Dir.glob(::Rails.root.join('app', 'subscribers', "*.rb")).each{ |file| load file }
end
logger() click to toggle source
# File lib/active_pubsub.rb, line 38
def self.logger
  configuration.logger
end
logger?() click to toggle source
# File lib/active_pubsub.rb, line 42
def self.logger?
  configuration.logger.present?
end
publisher() click to toggle source
# File lib/active_pubsub.rb, line 46
def self.publisher
  ::Celluloid::Actor[:rabbit_publisher]
end
publisher_disabled?() click to toggle source
# File lib/active_pubsub.rb, line 50
def self.publisher_disabled?
  configuration.publisher_disabled
end
start_publisher() click to toggle source
# File lib/active_pubsub.rb, line 54
def self.start_publisher
  ::ActivePubsub::Publisher.start unless ::ActivePubsub::Publisher.started?
end
start_subscribers() click to toggle source
# 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
symbolize_routing_key(routing_key) click to toggle source
# File lib/active_pubsub.rb, line 69
def self.symbolize_routing_key(routing_key)
  :"#{routing_key.split('.').join('_')}"
end