Module: Amigo::QueueBackoffJob::InstanceMethods

Defined in:
lib/amigo/queue_backoff_job.rb

Instance Method Summary collapse

Instance Method Details

#calculate_backoff(_queue_name, latency, _args) ⇒ Object 



121
122
123
 
# File 'lib/amigo/queue_backoff_job.rb', line 121

def calculate_backoff(_queue_name, latency, _args)
  return [latency, ::Amigo::QueueBackoffJob.max_backoff].min
end

#dependent_queues ⇒ Object 



116
117
118
119
 
# File 'lib/amigo/queue_backoff_job.rb', line 116

def dependent_queues
  qname = self.class.get_sidekiq_options["queue"]
  return ::Amigo::QueueBackoffJob.all_queue_names.reject { |x| x == qname }
end