class ActiveJob::QueueAdapters::StompJobAdapter
StompJob
adapter for Active Job¶ ↑
StompJob
is an ActiveJob
adapter for working with any message broker that accepts the STOMP protocol.
To use StompJob
set the queue_adapter config to :stomp_job
.
Rails.application.config.active_job.queue_adapter = :stomp_job
Public Class Methods
stomp_job_klasses()
click to toggle source
# File lib/stomp_job/extensions/active_job_adapter.rb, line 30 def self.stomp_job_klasses @stomp_job_klasses ||= {} end
stomp_worker_from_aj(aj_klass)
click to toggle source
# File lib/stomp_job/extensions/active_job_adapter.rb, line 23 def self.stomp_worker_from_aj(aj_klass) stomp_job_klasses[aj_klass] ||= Class.new do include StompJob::Worker stomp_options queue_name: aj_klass.queue_name end end
Public Instance Methods
enqueue(job)
click to toggle source
# File lib/stomp_job/extensions/active_job_adapter.rb, line 14 def enqueue(job) StompJobAdapter.stomp_worker_from_aj(job.class).enqueue(*job.arguments) end
enqueue_at(job, timestamp)
click to toggle source
# File lib/stomp_job/extensions/active_job_adapter.rb, line 18 def enqueue_at(job, timestamp) raise NotImplementedError, "Scheduling jobs is not currently supported by the StopmJob queueing backend." end