Module: QC::Later

Extended by:

Later

Included in:

Later

Defined in:

lib/queue_classic/later.rb,
lib/queue_classic/later/version.rb

Defined Under Namespace

Modules: Queries, QueueExtensions, Setup

Constant Summary

TABLE_NAME =

"queue_classic_later_jobs"

VERSION =

"0.3.0"

Instance Method Summary

• #tick ⇒ Object

  run QC::Later.tick as often as necessary via your clock process.

Instance Method Details

#tick ⇒ Object

run QC::Later.tick as often as necessary via your clock process

# File 'lib/queue_classic/later.rb', line 57

def tick
  QC::Conn.transaction do
    QC::Later::Queries.delete_and_capture(Time.now).each do |job|
      queue = QC::Queue.new(job["q_name"])
      queue.enqueue(job["method"], *JSON.parse(job["args"]))
    end
  end
end