class PubsubNotifier::Broadcasters::ActiveJobBroadcaster

Public Instance Methods

broadcast(subscriber, publisher, event, args) click to toggle source
# File lib/pubsub_notifier/broadcasters/active_job_broadcaster.rb, line 4
def broadcast(subscriber, publisher, event, args)
  configured_job.perform_later(subscriber.name, event, args)
rescue ActiveJob::SerializationError => e
  # NOTE: Fallback if global_id is blank
  logger.warn { e.inspect }
  configured_job.perform_now(subscriber.name, event, *args)
end

Private Instance Methods

configured_job() click to toggle source
# File lib/pubsub_notifier/broadcasters/active_job_broadcaster.rb, line 14
def configured_job
  BroadcastJob.set(options)
end
default_options() click to toggle source
# File lib/pubsub_notifier/broadcasters/active_job_broadcaster.rb, line 18
def default_options
  { wait: nil, wait_until: nil, queue: :default }
end