class AsyncJobAdapter
Definitions
def enqueue(job)
Enqueue a job for processing.
Implementation
def enqueue(job)
Sync do
@dispatcher.call(job)
end
end
def enqueue_at(job, timestamp)
Enqueue a job for processing at a specific time.
Implementation
def enqueue_at(job, timestamp)
Sync do
@dispatcher.call(job)
end
end