class ActiveJob::QueueAdapters::ShinqAdapter

Public Class Methods

enqueue(job) click to toggle source
# File lib/shinq/active_job/queue_adapters/shinq_adapter.rb, line 13
def enqueue(job)
  Shinq::Client.enqueue(
    table_name: job.queue_name,
    job_id: job.job_id,
    args: job.arguments.first
  )
end
enqueue_at(job, timestamp) click to toggle source
# File lib/shinq/active_job/queue_adapters/shinq_adapter.rb, line 21
def enqueue_at(job, timestamp)
  Shinq::Client.enqueue(
    table_name: job.queue_name,
    job_id: job.job_id,
    args: job.arguments.first,
    scheduled_at: timestamp,
  )
end

Public Instance Methods

enqueue(job) click to toggle source
# File lib/shinq/active_job/queue_adapters/shinq_adapter.rb, line 4
def enqueue(job)
  self.class.enqueue job
end
enqueue_at(job, timestamp) click to toggle source
# File lib/shinq/active_job/queue_adapters/shinq_adapter.rb, line 8
def enqueue_at(job, timestamp)
  self.class.enqueue_at job, timestamp
end