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 16 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