Module: Qu::Delayed

Included in:
Qu
Defined in:
lib/qu/delayed.rb,
lib/qu/delayed/worker.rb,
lib/qu/delayed/payload.rb,
lib/qu/delayed/backend/mongo.rb,
lib/qu/delayed/backend/immediate.rb

Defined Under Namespace

Modules: Backend Classes: Payload, Worker

Instance Method Summary collapse

Instance Method Details

#clear_delayed ⇒ Object 



18
19
20
 
# File 'lib/qu/delayed.rb', line 18

def clear_delayed
  backend.clear_delayed
end

#enqueue_at(run_at, klass, *args) ⇒ Object

Enqueues job to run at given time.



9
10
11
 
# File 'lib/qu/delayed.rb', line 9

def enqueue_at(run_at, klass, *args)
  backend.enqueue_at Qu::Delayed::Payload.new(:klass => klass, :run_at => run_at, :args => args)
end

#enqueue_in(run_in, klass, *args) ⇒ Object

Enqueues job to run in run_in seconds from now.



14
15
16
 
# File 'lib/qu/delayed.rb', line 14

def enqueue_in(run_in, klass, *args)
  backend.enqueue_at Qu::Delayed::Payload.new(:klass => klass, :run_at => Time.now + run_in, :args => args)
end