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.

Class Method Summary collapse

Class Method Details

.enqueue(job) ⇒ Object

Parameters:

  • job (ActiveJob::Base) 


7
8
9
10
11
12
13
 
# File 'lib/activejob/queue_adapters/dispatch_rider_adapter.rb', line 7

def enqueue(job)
  publisher.publish destinations: Array(job.queue_name),
                    message: {
                      subject: "dispatch_rider_active_job_handler",
                      body: job.serialize
                    }
end

.enqueue_at ⇒ Object

Raises:

  • (NotImplementedError) 


15
16
17
18
19
20
 
# File 'lib/activejob/queue_adapters/dispatch_rider_adapter.rb', line 15

def enqueue_at(*)
  raise NotImplementedError,
        "This queueing backend does not support scheduling jobs. To "\
        "see what features are supported go to "\
        "http://api.rubyonrails.org/classes/ActiveJob/QueueAdapters.html"
end