class Announce::Adapters::BaseAdapter
Public Class Methods
adapter_constantize(name)
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 31 def adapter_constantize(name) a_klass = Announce.options[:adapter].to_s.camelize klass = name.to_s.camelize "::Announce::Adapters::#{a_klass}Adapter::#{klass}".constantize end
configure_broker(options)
click to toggle source
required
# File lib/announce/adapters/base_adapter.rb, line 26 def configure_broker(options) broker_manager = adapter_constantize(:broker_manager).new(options) broker_manager.configure end
publish(subject, action, body, options = {})
click to toggle source
required
# File lib/announce/adapters/base_adapter.rb, line 12 def publish(subject, action, body, options = {}) topic = adapter_constantize(:topic).new(subject, action, options) msg = Announce::Message.new(subject: subject, action: action, body: body) topic.publish(msg.to_message, options) end
subscribe(worker_class, subject, actions = [], options = {})
click to toggle source
required
# File lib/announce/adapters/base_adapter.rb, line 20 def subscribe(worker_class, subject, actions = [], options = {}) subscriber = adapter_constantize(:subscriber).new subscriber.subscribe(worker_class, subject, actions, options) end