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