Module: Esse::AsyncIndexing::Workers::Faktory::ClassMethods

Defined in:
lib/esse/async_indexing/workers/faktory.rb

Instance Method Summary collapse

Instance Method Details

#service_worker_options ⇒ Object 



15
16
17
18
19
20
21
22
23
24
 
# File 'lib/esse/async_indexing/workers/faktory.rb', line 15

def service_worker_options
  default_queue = Esse.config.async_indexing.faktory.workers.dig(name, :queue)
  default_retry = Esse.config.async_indexing.faktory.workers.dig(name, :retry)
  default_queue ||= ::Faktory.default_job_options["queue"] if defined?(::Faktory)
  default_retry ||= ::Faktory.default_job_options["retry"] if defined?(::Faktory)
  {
    queue: default_queue || "default",
    retry: default_retry || 25
  }
end