class ActiveJob::QueueAdapters::TestAdapter

Attributes

enqueued_jobs[W]
perform_enqueued_at_jobs[RW]
perform_enqueued_jobs[RW]
performed_jobs[W]

Public Instance Methods

enqueue(job) click to toggle source
# File lib/active_job/queue_adapters/test_adapter.rb, line 21
def enqueue(job)
  if perform_enqueued_jobs
    performed_jobs << {job: job.class, args: job.arguments, queue: job.queue_name}
    job.perform_now
  else
    enqueued_jobs << {job: job.class, args: job.arguments, queue: job.queue_name}
  end
end
enqueue_at(job, timestamp) click to toggle source
# File lib/active_job/queue_adapters/test_adapter.rb, line 30
def enqueue_at(job, timestamp)
  if perform_enqueued_at_jobs
    performed_jobs << {job: job.class, args: job.arguments, queue: job.queue_name, at: timestamp}
    job.perform_now
  else
    enqueued_jobs << {job: job.class, args: job.arguments, queue: job.queue_name, at: timestamp}
  end
end
enqueued_jobs() click to toggle source

Provides a store of all the enqueued jobs with the TestAdapter so you can check them.

# File lib/active_job/queue_adapters/test_adapter.rb, line 8
def enqueued_jobs
  @enqueued_jobs ||= []
end
name() click to toggle source
# File lib/active_job/queue_adapters/test_adapter.rb, line 12
def name
  self.class.name
end
performed_jobs() click to toggle source

Provides a store of all the performed jobs with the TestAdapter so you can check them.

# File lib/active_job/queue_adapters/test_adapter.rb, line 17
def performed_jobs
  @performed_jobs ||= []
end