Module: Announcer

Defined in:
lib/announcer.rb,
lib/announcer/event.rb,
lib/announcer/config.rb,
lib/announcer/errors.rb,
lib/announcer/mixins.rb,
lib/announcer/plugins.rb,
lib/announcer/version.rb,
lib/announcer/instance.rb,
lib/announcer/publishers.rb,
lib/announcer/subscription.rb,
lib/announcer/plugins/plugin.rb,
lib/announcer/mixins/has_config.rb,
lib/announcer/mixins/has_instance.rb,
lib/announcer/mixins/serializable.rb,
lib/announcer/publishers/publisher.rb,
lib/announcer/plugins/logging_plugin.rb,
lib/announcer/publishers/proc_publisher.rb,
lib/announcer/publishers/resque_publisher.rb,
lib/announcer/publishers/async_resque_publisher.rb,
lib/announcer/publishers/remote_resque_publisher.rb

Defined Under Namespace

Modules: Errors, Mixins, Plugins, Publishers Classes: Config, Event, Instance, Subscription

Constant Summary collapse

VERSION = 
"0.5.2"
DEFAULT_CONFIG_PATH = 
File.expand_path('../../../config/defaults.yml', __FILE__).freeze

Class Method Summary collapse

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(meth, *args, &block) ⇒ Object (private) 



13
14
15
 
# File 'lib/announcer.rb', line 13

def method_missing(meth, *args, &block)
  instance.send(meth, *args, &block)
end

Class Method Details

._register_instance(instance) ⇒ Object 



25
26
27
28
29
30
31
 
# File 'lib/announcer.rb', line 25

def _register_instance(instance)
  if _registered_instances.key?(instance.name)
    raise Errors::DuplicateInstanceNameError, instance.name
  else
    _registered_instances[instance.name] = instance
  end
end

._registered_instances ⇒ Object 



21
22
23
 
# File 'lib/announcer.rb', line 21

def _registered_instances
  @__registered_instances ||= {}
end

.instance(name = :primary) ⇒ Object 



17
18
19
 
# File 'lib/announcer.rb', line 17

def instance(name=:primary)
  _registered_instances[name.to_sym] || Instance.new(name)
end

.method_missing(meth, *args, &block) ⇒ Object 



13
14
15
 
# File 'lib/announcer.rb', line 13

def method_missing(meth, *args, &block)
  instance.send(meth, *args, &block)
end