class Resque::Job
Public Class Methods
create_solo(queue, klass, *args)
click to toggle source
Mark an item as queued
# File lib/resque_ext/job.rb, line 7 def create_solo(queue, klass, *args) item = { class: klass.to_s, args: args } if Resque.inline? || !ResqueSolo::Queue.is_unique?(item) return create_without_solo(queue, klass, *args) end return "EXISTED" if ResqueSolo::Queue.queued?(queue, item) create_return_value = false # redis transaction block Resque.redis.multi do create_return_value = create_without_solo(queue, klass, *args) ResqueSolo::Queue.mark_queued(queue, item) end create_return_value end
Also aliased as: create
destroy_solo(queue, klass, *args)
click to toggle source
Mark destroyed jobs as unqueued
# File lib/resque_ext/job.rb, line 30 def destroy_solo(queue, klass, *args) ResqueSolo::Queue.destroy(queue, klass, *args) unless Resque.inline? destroy_without_solo(queue, klass, *args) end
Also aliased as: destroy
reserve_solo(queue)
click to toggle source
Mark an item as unqueued
# File lib/resque_ext/job.rb, line 23 def reserve_solo(queue) item = reserve_without_solo(queue) ResqueSolo::Queue.mark_unqueued(queue, item) if item && !Resque.inline? item end
Also aliased as: reserve