class Resque::Job

Public Class Methods

create(queue, klass, *args)
Also aliased as: create_without_solo
Alias for: create_solo
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
create_without_solo(queue, klass, *args)
Alias for: create
destroy(queue, klass, *args)
Also aliased as: destroy_without_solo
Alias for: destroy_solo
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
destroy_without_solo(queue, klass, *args)
Alias for: destroy
reserve(queue)
Also aliased as: reserve_without_solo
Alias for: reserve_solo
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
reserve_without_solo(queue)
Alias for: reserve