class Announce::Adapters::InlineAdapter::Subscriber

Public Instance Methods

subscribe(worker_class, subject, actions, options) click to toggle source
# File lib/announce/adapters/inline_adapter.rb, line 15
def subscribe(worker_class, subject, actions, options)
  Array(actions).each do |action|
    queue_name = Queue.name_for(subject, action)
    InlineAdapter.subscriptions[queue_name] = worker_class
  end
end