class Announce::Adapters::InlineAdapter::Topic
Public Instance Methods
publish(message, options = {})
click to toggle source
# File lib/announce/adapters/inline_adapter.rb, line 25 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