module MultipleMan

Constants

ConnectionError
ConsumerError
Error
ProducerError
VERSION

Public Class Methods

configuration() click to toggle source
# File lib/multiple_man/configuration.rb, line 2
def self.configuration
  @configuration ||= Configuration.new
end
configure() { |configuration| ... } click to toggle source
# File lib/multiple_man/configuration.rb, line 6
def self.configure
  yield(configuration) if block_given?
end
disable!() click to toggle source
# File lib/multiple_man.rb, line 41
def self.disable!
  configuration.enabled = false
end
enable!() click to toggle source
# File lib/multiple_man.rb, line 45
def self.enable!
  configuration.enabled = true
end
error(ex, options = {}) click to toggle source
# File lib/multiple_man.rb, line 49
def self.error(ex, options = {})
  raise ex unless configuration.error_handler

  if configuration.error_handler.arity == 3
    configuration.error_handler.call(ex, options[:payload], options[:delivery_info])
  else
    configuration.error_handler.call(ex)
  end

  raise ex if configuration.reraise_errors && options[:reraise] != false
end
logger() click to toggle source
# File lib/multiple_man.rb, line 37
def self.logger
  configuration.logger
end
publish(klass, options) click to toggle source
# File lib/multiple_man/publish.rb, line 2
def self.publish(klass, options)
  klass.send(:include, MultipleMan::Publisher)
  klass.publish options
end