Class: ActiveJob::QueueAdapters::DispatchRiderAdapter
- Inherits:
-
Object
- Object
- ActiveJob::QueueAdapters::DispatchRiderAdapter
- 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
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
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 |