class ActiveJob::QueueAdapters::QuberAdapter

Public Class Methods

new(options = {}) click to toggle source
# File lib/active_job/queue_adapters/quber_adapter.rb, line 5
def initialize options = {}
  @client ||= Quber::Client.new options
end

Public Instance Methods

enqueue(job, attributes = {}) click to toggle source
# File lib/active_job/queue_adapters/quber_adapter.rb, line 9
def enqueue(job, attributes = {})
  task = build_task(job, attributes)
  @client.put task
end
enqueue_at(job, timestamp) click to toggle source
# File lib/active_job/queue_adapters/quber_adapter.rb, line 14
def enqueue_at(job, timestamp)
  enqueue job, scheduled_at: timestamp
end

Private Instance Methods

build_task(job, attributes) click to toggle source
# File lib/active_job/queue_adapters/quber_adapter.rb, line 20
def build_task(job, attributes)
  { data: job.serialize, **attributes }
end