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