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