module Backburner::Queue::ClassMethods

Public Instance Methods

queue(name=nil) click to toggle source

Returns or assigns queue name for this job.

@example

queue "some.task.name"
@klass.queue # => "some.task.name"
# File lib/backburner/queue.rb, line 21
def queue(name=nil)
  if name
    @queue_name = name
  else # accessor
    (@queue_name.is_a?(Proc) ? @queue_name.call(self) : @queue_name) || Backburner.configuration.primary_queue
  end
end
queue_garbage_limit(limit=nil) click to toggle source

Returns or assigns queue jobs garbage limit (only ThreadsOnFork Worker)

@example

queue_garbage_limit 1000
@klass.queue_garbage_limit # => 1000
# File lib/backburner/queue.rb, line 77
def queue_garbage_limit(limit=nil)
  if limit
    @queue_garbage_limit = limit
  else #accessor
    @queue_garbage_limit
  end
end
queue_jobs_limit(limit=nil) click to toggle source

Returns or assigns queue parallel active jobs limit (only ThreadsOnFork and Threading workers)

@example

queue_jobs_limit 5
@klass.queue_jobs_limit # => 5
# File lib/backburner/queue.rb, line 63
def queue_jobs_limit(limit=nil)
  if limit
    @queue_jobs_limit = limit
  else #accessor
    @queue_jobs_limit
  end
end
queue_priority(pri=nil) click to toggle source

Returns or assigns queue priority for this job

@example

queue_priority 120
@klass.queue_priority # => 120
# File lib/backburner/queue.rb, line 35
def queue_priority(pri=nil)
  if pri
    @queue_priority = pri
  else # accessor
    @queue_priority
  end
end
queue_respond_timeout(ttr=nil) click to toggle source

Returns or assigns queue respond_timeout for this job

@example

queue_respond_timeout 120
@klass.queue_respond_timeout # => 120
# File lib/backburner/queue.rb, line 49
def queue_respond_timeout(ttr=nil)
  if ttr
    @queue_respond_timeout = ttr
  else # accessor
    @queue_respond_timeout
  end
end
queue_retry_limit(limit=nil) click to toggle source

Returns or assigns queue retry limit (only ThreadsOnFork worker)

@example

queue_retry_limit 6
@klass.queue_retry_limit # => 6
# File lib/backburner/queue.rb, line 91
def queue_retry_limit(limit=nil)
  if limit
    @queue_retry_limit = limit
  else #accessor
    @queue_retry_limit
  end
end