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