class Dynflow::ActiveJob::QueueAdapters::DynflowAdapter

To use Dynflow, set the queue_adapter config to :dynflow.

Rails.application.config.active_job.queue_adapter = :dynflow

Public Class Methods

enqueue(job) click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 11
def enqueue(job)
  ::Rails.application.dynflow.world.trigger(JobWrapper, job.serialize)
end
enqueue_at(job, timestamp) click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 15
def enqueue_at(job, timestamp)
  ::Rails.application.dynflow.world.delay(JobWrapper, { :start_at => Time.at(timestamp) }, job.serialize)
end