Class: Announce::Adapters::InlineAdapter::Subscriber

Inherits:

BaseAdapter::Subscriber

• Object
• BaseAdapter::Subscriber
• Announce::Adapters::InlineAdapter::Subscriber

Defined in:

lib/announce/adapters/inline_adapter.rb

Instance Method Summary

• #subscribe(worker_class, subject, actions, options) ⇒ Object

Instance Method Details

#subscribe(worker_class, subject, actions, options) ⇒ Object

# 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