lib/backburner/queue.rb in backburner-0.4.5 vs lib/backburner/queue.rb in backburner-0.4.6

- old
+ new

@@ -45,8 +45,50 @@ @queue_respond_timeout = ttr else # accessor @queue_respond_timeout end end + + # Returns or assigns queue parallel active jobs limit (only ThreadsOnFork Worker) + # + # @example + # queue_jobs_limit 5 + # @klass.queue_jobs_limit # => 5 + # + def queue_jobs_limit(limit=nil) + if limit + @queue_jobs_limit = limit + else #accessor + @queue_jobs_limit + end + end + + # Returns or assigns queue jobs garbage limit (only ThreadsOnFork Worker) + # + # @example + # queue_garbage_limit 1000 + # @klass.queue_garbage_limit # => 1000 + # + def queue_garbage_limit(limit=nil) + if limit + @queue_garbage_limit = limit + else #accessor + @queue_garbage_limit + end + end + + # Returns or assigns queue retry limit (only ThreadsOnFork Worker) + # + # @example + # queue_retry_limit 6 + # @klass.queue_retry_limit # => 6 + # + def queue_retry_limit(limit=nil) + if limit + @queue_retry_limit = limit + else #accessor + @queue_retry_limit + end + end end # ClassMethods end # Queue -end # Backburner \ No newline at end of file +end # Backburner