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