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 



128
129
130
 
# File 'lib/amigo/queue_backoff_job.rb', line 128

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

#dependent_queues ⇒ Object 



123
124
125
126
 
# File 'lib/amigo/queue_backoff_job.rb', line 123

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