Sha256: dd769ec3a911a8b335e6ad7bcb33646f07c329917f0eb6986fb227104b7c0e6e
Contents?: true
Size: 1.04 KB
Versions: 51
Compression:
Stored size: 1.04 KB
Contents
require 'que'
module ActiveJob
module QueueAdapters
# == Que adapter for Active Job
#
# Que is a high-performance alternative to DelayedJob or QueueClassic that
# improves the reliability of your application by protecting your jobs with
# the same ACID guarantees as the rest of your data. Que is a queue for
# Ruby and PostgreSQL that manages jobs using advisory locks.
#
# Read more about Que {here}[https://github.com/chanks/que].
#
# To use Que set the queue_adapter config to +:que+.
#
# Rails.application.config.active_job.queue_adapter = :que
class QueAdapter
class << self
def enqueue(job) #:nodoc:
JobWrapper.enqueue job.serialize, queue: job.queue_name
end
def enqueue_at(job, timestamp) #:nodoc:
JobWrapper.enqueue job.serialize, queue: job.queue_name, run_at: Time.at(timestamp)
end
end
class JobWrapper < Que::Job #:nodoc:
def run(job_data)
Base.execute job_data
end
end
end
end
end
Version data entries
51 entries across 50 versions & 8 rubygems