Class: ActiveJob::QueueAdapters::LambdakiqAdapter

Inherits:

Object

Object
ActiveJob::QueueAdapters::LambdakiqAdapter

Defined in:: lib/lambdakiq/adapter.rb

Instance Method Summary collapse

Instance Method Details

#enqueue(job, options = {}) ⇒ `Object`



5
6
7

# File 'lib/lambdakiq/adapter.rb', line 5

def enqueue(job, options = {})
  job.lambdakiq_async? ? _enqueue_async(job, options) : _enqueue(job, options)
end

#enqueue_at(job, timestamp) ⇒ `Object`



9
10
11

# File 'lib/lambdakiq/adapter.rb', line 9

def enqueue_at(job, timestamp)
  enqueue job, delay_seconds: delay_seconds(timestamp)
end