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/connection.rb,
lib/multiple_man/routing_key.rb,
lib/multiple_man/configuration.rb,
lib/multiple_man/mixins/listener.rb,
lib/multiple_man/model_populator.rb,
lib/multiple_man/model_publisher.rb,
lib/multiple_man/mixins/publisher.rb,
lib/multiple_man/mixins/subscriber.rb,
lib/multiple_man/payload_generator.rb,
lib/multiple_man/attribute_extractor.rb

Defined Under Namespace

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

Constant Summary collapse

VERSION = 
"0.6.0"

Class Method Summary collapse

Class Method Details

.configuration ⇒ Object 



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

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

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

Yields:



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

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

.disable! ⇒ Object 



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

def self.disable!
  configuration.enabled = false
end

.enable! ⇒ Object 



33
34
35
 
# File 'lib/multiple_man.rb', line 33

def self.enable!
  configuration.enabled = true
end

.error(ex, options = {}) ⇒ Object 



37
38
39
40
41
42
43
44
 
# File 'lib/multiple_man.rb', line 37

def self.error(ex, options = {})
  if configuration.error_handler
    configuration.error_handler.call(ex)
    raise ex if configuration.reraise_errors && options[:reraise] != false
  else
    raise ex
  end
end

.logger ⇒ Object 



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

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