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