class Announce::Adapters::InlineAdapter::Topic

Public Instance Methods

publish(message, options = {}) click to toggle source
# File lib/announce/adapters/inline_adapter.rb, line 24
def publish(message, options = {})
  queue_name = Queue.name_for(subject, action)
  worker_class = InlineAdapter.subscriptions[queue_name]
  if defined?(::ActiveJob)
    job = worker_class.new(message)
    ::ActiveJob::Base.execute(job.serialize)
  else
    worker_class.new.perform(message)
  end
end