class Announce::Adapters::BaseAdapter

Public Class Methods

adapter_constantize(name) click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 29
def adapter_constantize(name)
  "::Announce::Adapters::#{Announce.options[:adapter].to_s.camelize}Adapter::#{name.to_s.camelize}".constantize
end
configure_broker(options) click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 24
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
# File lib/announce/adapters/base_adapter.rb, line 13
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
# File lib/announce/adapters/base_adapter.rb, line 19
def subscribe(worker_class, subject, actions = [], options = {})
  subscriber = adapter_constantize(:subscriber).new
  subscriber.subscribe(worker_class, subject, actions, options)
end