Module: MultipleMan

Defined in:
lib/multiple_man.rb,
lib/multiple_man/publish.rb,
lib/multiple_man/railtie.rb,
lib/multiple_man/version.rb,
lib/multiple_man/identity.rb,
lib/multiple_man/listener.rb,
lib/multiple_man/connection.rb,
lib/multiple_man/routing_key.rb,
lib/multiple_man/configuration.rb,
lib/multiple_man/model_populator.rb,
lib/multiple_man/model_publisher.rb,
lib/multiple_man/seeder_listener.rb,
lib/multiple_man/mixins/publisher.rb,
lib/multiple_man/mixins/subscriber.rb,
lib/multiple_man/attribute_extractor.rb

Defined Under Namespace

Modules: Publisher, Subscriber, Subscribers Classes: AttributeExtractor, Configuration, Connection, Identity, Listener, ModelPopulator, ModelPublisher, Railtie, RoutingKey, SeederListener

Constant Summary collapse

VERSION = 
"0.5.8"

Class Method Summary collapse

Class Method Details

.configuration ⇒ Object 



25
26
27
 
# File 'lib/multiple_man/configuration.rb', line 25

def self.configuration
  @configuration ||= Configuration.new
end

.configure {|configuration| ... } ⇒ Object

Yields:



29
30
31
 
# File 'lib/multiple_man/configuration.rb', line 29

def self.configure
  yield(configuration) if block_given?
end

.disable! ⇒ Object 



26
27
28
 
# File 'lib/multiple_man.rb', line 26

def self.disable!
  configuration.enabled = false
end

.enable! ⇒ Object 



30
31
32
 
# File 'lib/multiple_man.rb', line 30

def self.enable!
  configuration.enabled = true
end

.error(ex) ⇒ Object 



34
35
36
37
38
39
40
 
# File 'lib/multiple_man.rb', line 34

def self.error(ex)
  if configuration.error_handler
    configuration.error_handler.call(ex)
  else
    raise ex
  end
end

.logger ⇒ Object 



22
23
24
 
# File 'lib/multiple_man.rb', line 22

def self.logger
  configuration.logger
end

.publish(klass, options) ⇒ Object 



2
3
4
5
 
# File 'lib/multiple_man/publish.rb', line 2

def self.publish(klass, options)
  klass.send(:include, MultipleMan::Publisher)
  klass.publish options
end