Class: ActiveJob::QueueAdapters::DispatchRiderAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/activejob/queue_adapters/dispatch_rider_adapter.rb

Overview

Adds support for DispatchRider to ActiveJob.

Instance Method Summary collapse

Instance Method Details

#enqueue(job) ⇒ Object

Parameters:

  • job (ActiveJob::Base) 


6
7
8
 
# File 'lib/activejob/queue_adapters/dispatch_rider_adapter.rb', line 6

def enqueue(job)
  publisher.publish **job_details_for(job)
end

#enqueue_at(job, scheduled_at) ⇒ Object

Parameters:

  • job (ActiveJob::Base)
  • scheduled_at (Float) —

    • float representing time (blame AJ)



12
13
14
15
16
 
# File 'lib/activejob/queue_adapters/dispatch_rider_adapter.rb', line 12

def enqueue_at(job, scheduled_at)
  scheduled_job_details = job_details_for(job).merge(scheduled_at: Time.at(scheduled_at))

  ::DispatchRider::ScheduledJob.create! **scheduled_job_details
end