Async::Job::Adapter::AsyncJob SourceActiveJobQueueAdaptersAsyncJobAdapter

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